From b45cf4ba6a280749d39fc97cb98c2c518d1c5ff9 Mon Sep 17 00:00:00 2001 From: ClownXC Date: Tue, 17 Dec 2024 09:36:55 +0800 Subject: [PATCH] Fix KafkaSourceSplitEnumeratorTest --- .../kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java b/seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java index 00e059ecfe9..eaf022eca9c 100644 --- a/seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/kafka/clients/admin/KafkaSourceSplitEnumeratorTest.java +++ b/seatunnel-connectors-v2/connector-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