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
index 391dc1e..b7b6c07 100644
--- 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);
         }