From 21ef43fee998c897d98814b6c36b0c0153ba3b61 Mon Sep 17 00:00:00 2001 From: Farooq Qaiser Date: Tue, 9 Apr 2024 14:10:42 -0400 Subject: [PATCH] sigh --- kafka-connect-runtime/build.gradle | 1 + .../io/tabular/iceberg/connect/KafkaConnectContainer.java | 6 ++++++ 2 files changed, 7 insertions(+) diff --git a/kafka-connect-runtime/build.gradle b/kafka-connect-runtime/build.gradle index 67f48b87..abe18059 100644 --- a/kafka-connect-runtime/build.gradle +++ b/kafka-connect-runtime/build.gradle @@ -81,6 +81,7 @@ dependencies { testImplementation libs.testcontainers testImplementation libs.testcontainers.kafka testImplementation libs.http.client + testImplementation 'ch.qos.logback:logback-classic:1.1.2' } processResources { diff --git a/kafka-connect-runtime/src/test/java/io/tabular/iceberg/connect/KafkaConnectContainer.java b/kafka-connect-runtime/src/test/java/io/tabular/iceberg/connect/KafkaConnectContainer.java index dfa6f2de..0afcd66b 100644 --- a/kafka-connect-runtime/src/test/java/io/tabular/iceberg/connect/KafkaConnectContainer.java +++ b/kafka-connect-runtime/src/test/java/io/tabular/iceberg/connect/KafkaConnectContainer.java @@ -37,12 +37,17 @@ import org.apache.iceberg.relocated.com.google.common.collect.Lists; import org.apache.iceberg.relocated.com.google.common.collect.Maps; import org.awaitility.Awaitility; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.testcontainers.containers.GenericContainer; +import org.testcontainers.containers.output.Slf4jLogConsumer; import org.testcontainers.containers.wait.strategy.HttpWaitStrategy; import org.testcontainers.utility.DockerImageName; public class KafkaConnectContainer extends GenericContainer { + private static final Logger LOG = LoggerFactory.getLogger(KafkaConnectContainer.class); + private static final HttpClient HTTP = HttpClients.createDefault(); private static final int PORT = 8083; @@ -90,6 +95,7 @@ public KafkaConnectContainer(DockerImageName dockerImageName) { .forPath("/connectors") .forPort(PORT) .withStartupTimeout(Duration.ofSeconds(30))); + this.withLogConsumer(new Slf4jLogConsumer(LOG)); } public void startConnector(Config config) {