log from kafka containers

questdb · Apr 5, 2024 · f9f26bc · f9f26bc
1 parent 452807e
commit f9f26bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java b/integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java
@@ -155,8 +155,8 @@ private static KafkaContainer newKafkaContainer(int id) {
                     .withEnv("KAFKA_NUM_PARTITIONS", "3")
                     .withEnv("KAFKA_CONTROLLER_QUORUM_VOTERS", votersBuilder.toString())
                     .withFileSystemBind(kafkaData.toAbsolutePath().toString(), "/var/lib/kafka/data")
-                    .withCreateContainerCmdModifier(cmd -> cmd.withHostName("kafka" + id));
-//                    .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("kafka" + id)));
+                    .withCreateContainerCmdModifier(cmd -> cmd.withHostName("kafka" + id))
+                    .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("kafka" + id)));
         } catch (IOException e) {
             throw new RuntimeException(e);
         }