This is an automated email from the ASF dual-hosted git repository. rgoers pushed a commit to branch Upgrade-to-Kafka-4 in repository https://gitbox.apache.org/repos/asf/logging-flume-kafka.git
commit 800ae3cebe9af912655412620a4df4d1276170eb Author: Ralph Goers <[email protected]> AuthorDate: Sun Jun 28 07:25:09 2026 -0700 Fix KafkaSinnk tests --- .../test/java/org/apache/flume/sink/kafka/TestKafkaSink.java | 3 ++- pom.xml | 11 +++++++++++ 2 files changed, 13 insertions(+), 1 deletion(-) diff --git a/flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java b/flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java index 8adfc23..12424aa 100644 --- a/flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java +++ b/flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java @@ -93,6 +93,7 @@ public class TestKafkaSink { topicsList.add(TestConstants.CUSTOM_TOPIC); topicsList.add(TestConstants.TRANSACTIONS_TOPIC); topicsList.add(TestConstants.HEADER_1_VALUE + "-topic"); + testUtil.createTopics(topicsList, 1); testUtil.initTopicList(topicsList); } @@ -677,7 +678,7 @@ public class TestKafkaSink { Properties props = new Properties(); props.put("bootstrap.servers", testUtil.getKafkaServerUrl()); - props.put("group.id", "group_1"); + props.put("group.id", "partition-test-" + java.util.UUID.randomUUID()); props.put("enable.auto.commit", "true"); props.put("auto.commit.interval.ms", "1000"); props.put("session.timeout.ms", "30000"); diff --git a/pom.xml b/pom.xml index 6aa1557..64884f6 100644 --- a/pom.xml +++ b/pom.xml @@ -231,6 +231,17 @@ </dependencyManagement> <build> <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <dependencies> + <dependency> + <groupId>org.junit.vintage</groupId> + <artifactId>junit-vintage-engine</artifactId> + <version>5.13.1</version> + </dependency> + </dependencies> + </plugin> <plugin> <groupId>org.apache.rat</groupId> <artifactId>apache-rat-plugin</artifactId>
