SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Simplify isSerdeFromStandardDefaults in KeyValueSerdeResolver

Browse Source 
Resolves #737
This commit is contained in:
Oleg Zhurakousky
2019-09-04 16:33:54 +02:00
parent 309f588325
commit 10de84f4fe
1 changed files with 1 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java
View File

@@ -367,19 +367,7 @@ public class KeyValueSerdeResolver implements ApplicationContextAware {
private boolean isSerdeFromStandardDefaults(Serde<?> serde) {
if (serde != null) {
if (Serdes.Integer().getClass().isAssignableFrom(serde.getClass())) {
return true;
}
else if (Serdes.Long().getClass().isAssignableFrom(serde.getClass())) {
return true;
}
else if (Serdes.Short().getClass().isAssignableFrom(serde.getClass())) {
return true;
}
else if (Serdes.Double().getClass().isAssignableFrom(serde.getClass())) {
return true;
}
else if (Serdes.Float().getClass().isAssignableFrom(serde.getClass())) {
if (Number.class.isAssignableFrom(serde.getClass())) {
return true;
}
else if (Serdes.ByteArray().getClass().isAssignableFrom(serde.getClass())) {