From 17cd491ea9a2664e204f963ee9d50b2b00b17487 Mon Sep 17 00:00:00 2001
From: Yoann Vernageau <6807151+yvrng@users.noreply.github.com>
Date: Mon, 23 Sep 2024 18:48:12 +0200
Subject: [PATCH] test: add unit tests

---
 .../io/kestra/plugin/kafka/KafkaTest.java     | 22 +++++++++----------
 1 file changed, 10 insertions(+), 12 deletions(-)

diff --git a/src/test/java/io/kestra/plugin/kafka/KafkaTest.java b/src/test/java/io/kestra/plugin/kafka/KafkaTest.java
index 56913b0..40b12be 100644
--- 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"
+                    }
+                  ]
+                }
               }
             ]
           }