Update seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-kafka…

…-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/kafka/KafkaSourceTextToConsoleIT.java Co-authored-by: hailin0 <hailin088@gmail.com>
apache · Oct 18, 2022 · 9265e26 · 9265e26
1 parent 8aaa809
commit 9265e26
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/kafka/KafkaSourceTextToConsoleIT.java b/...e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/kafka/KafkaSourceTextToConsoleIT.java
@@ -74,7 +74,7 @@ public void startKafkaContainer() {
         kafkaContainer = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"))
                 .withNetwork(NETWORK)
                 .withNetworkAliases(KAFKA_HOST)
-                .withLogConsumer(new Slf4jLogConsumer(log));
+                .withLogConsumer(new Slf4jLogConsumer(DockerLoggerFactory.getLogger("confluentinc/cp-kafka:6.2.1")));
         kafkaContainer.setPortBindings(Lists.newArrayList(
                 String.format("%s:%s", KAFKA_PORT, KAFKA_PORT)));
         Startables.deepStart(Stream.of(kafkaContainer)).join();