From f9f26bc0d7a0dea084c9a7b789af53c15bb5d8a9 Mon Sep 17 00:00:00 2001 From: Jaromir Hamala Date: Fri, 5 Apr 2024 16:04:36 +0200 Subject: [PATCH] log from kafka containers --- .../src/test/java/io/questdb/kafka/ExactlyOnceIT.java | 4 ++-- 1 file changed, 2 insertions(+), 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 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); }