Fix KafkaSourceSplitEnumeratorTest

TongchengOpenSource · Dec 17, 2024 · b45cf4b · b45cf4b
1 parent d188f6e
commit b45cf4b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...or-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java b/...or-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java
@@ -21,6 +21,7 @@
 import org.apache.seatunnel.connectors.seatunnel.kafka.source.KafkaSourceSplitEnumerator;
 
 import org.apache.kafka.common.KafkaFuture;
+import org.apache.kafka.common.Node;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.TopicPartitionInfo;
 
@@ -74,7 +75,9 @@ void init() {
                                                                 Collections.singletonList(
                                                                         new TopicPartitionInfo(
                                                                                 0,
-                                                                                null,
+                                                                                new Node(
+                                                                                        2, "",
+                                                                                        18080),
                                                                                 Collections
                                                                                         .emptyList(),
                                                                                 Collections