test: add unit tests

kestra-io · Sep 23, 2024 · 17cd491 · 17cd491
1 parent 7670e26
commit 17cd491
Showing 1 changed file with 10 additions and 12 deletions.
diff --git a/src/test/java/io/kestra/plugin/kafka/KafkaTest.java b/src/test/java/io/kestra/plugin/kafka/KafkaTest.java
@@ -53,18 +53,16 @@ public class KafkaTest {
               },
               {
                 "name": "stat",
-                "type": [
-                  "null", {
-                    "type": "record",
-                    "name": "stat",
-                    "fields": [
-                      {
-                        "name": "followers_count",
-                        "type": "long"
-                      }
-                    ]
-                  }
-                ]
+                "type": {
+                  "type": "record",
+                  "name": "stat",
+                  "fields": [
+                    {
+                      "name": "followers_count",
+                      "type": "long"
+                    }
+                  ]
+                }
               }
             ]
           }