sigh

databricks · Apr 9, 2024 · 21ef43f · 21ef43f
1 parent c5b3d2d
commit 21ef43f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git 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
@@ -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<KafkaConnectContainer> {
 
+  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) {