feat(topicdata): allow integer/long to be serialized as float/double …

…when using AVRO schema. (#1123) close #1122
tchiotludo · Jun 19, 2022 · 82cda2a · 82cda2a
1 parent 6a01000
commit 82cda2a
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/main/java/org/akhq/utils/AvroSerializer.java b/src/main/java/org/akhq/utils/AvroSerializer.java
@@ -123,13 +123,23 @@ private static Object objectSerializer(Object value, Schema schema) {
                 case INT:
                     return value;
                 case LONG:
-                    if (value != null && value instanceof Integer) {
+                   if (value instanceof Integer) {
                         return ((Integer) value).longValue();
                     }
                     return value;
                 case FLOAT:
+                    if (value instanceof Integer) {
+                        return ((Integer) value).floatValue();
+                    } else if (value instanceof Long) {
+                        return ((Long) value).floatValue();
+                    }
                     return value;
                 case DOUBLE:
+                    if (value instanceof Integer) {
+                        return ((Integer) value).doubleValue();
+                    } else if (value instanceof Long) {
+                        return ((Long) value).doubleValue();
+                    }
                     return value;
                 case BOOLEAN:
                     return value;