We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 452807e commit f9f26bcCopy full SHA for f9f26bc
integration-tests/exactlyonce/src/test/java/io/questdb/kafka/ExactlyOnceIT.java
@@ -155,8 +155,8 @@ private static KafkaContainer newKafkaContainer(int id) {
155
.withEnv("KAFKA_NUM_PARTITIONS", "3")
156
.withEnv("KAFKA_CONTROLLER_QUORUM_VOTERS", votersBuilder.toString())
157
.withFileSystemBind(kafkaData.toAbsolutePath().toString(), "/var/lib/kafka/data")
158
- .withCreateContainerCmdModifier(cmd -> cmd.withHostName("kafka" + id));
159
-// .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("kafka" + id)));
+ .withCreateContainerCmdModifier(cmd -> cmd.withHostName("kafka" + id))
+ .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("kafka" + id)));
160
} catch (IOException e) {
161
throw new RuntimeException(e);
162
}
0 commit comments