Fix float values (#4)

onliner · Feb 5, 2024 · ed386e3 · ed386e3
1 parent 2466d52
commit ed386e3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/kotlin/org/onliner/kafka/transforms/JsonDeserialize.kt b/src/main/kotlin/org/onliner/kafka/transforms/JsonDeserialize.kt
@@ -143,11 +143,11 @@ abstract class JsonDeserialize<R : ConnectRecord<R>?> : Transformation<R> {
     {
         return when (schema.type()) {
             Schema.Type.BOOLEAN -> value.booleanValue()
-            Schema.Type.FLOAT64 -> value.floatValue()
-            Schema.Type.FLOAT32 -> value.doubleValue()
             Schema.Type.INT16 -> value.shortValue()
             Schema.Type.INT32 -> value.intValue()
             Schema.Type.INT64 -> value.longValue()
+            Schema.Type.FLOAT32 -> value.floatValue()
+            Schema.Type.FLOAT64 -> value.doubleValue()
             Schema.Type.STRING, Schema.Type.BYTES -> value.textValue()
             Schema.Type.STRUCT -> {
                 val struct = Struct(schema)