fixup! feat(e2e): add e2e tests

Use testcontainer logging consumer instead
Aiven-Open · Aug 29, 2023 · d0eaa36 · d0eaa36
1 parent d7daa4a
commit d0eaa36
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/e2e/src/test/java/io/aiven/kafka/tieredstorage/e2e/SingleBrokerTest.java b/e2e/src/test/java/io/aiven/kafka/tieredstorage/e2e/SingleBrokerTest.java
@@ -69,6 +69,7 @@
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.Network;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
 import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
 
@@ -162,6 +163,7 @@ static void setupKafka(final Consumer<KafkaContainer> tsPluginSetup) throws Exce
             .withCreateContainerCmdModifier(
                 cmd -> cmd.getHostConfig().withUlimits(List.of(new Ulimit("nofile", 30_000L, 30_000L))))
             .withFileSystemBind(localDataDir.toString(), KAFKA_DATA_DIR_CONTAINER)
+            .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("kafka")))
             .withNetwork(NETWORK);
 
         tsPluginSetup.accept(kafka);
@@ -182,11 +184,6 @@ static void stopKafka() {
             adminClient.close();
         }
 
-        if (FailFastExtension.failed) {
-            LOG.info("Kafka container logs:");
-            LOG.info(kafka.getLogs());
-        }
-
         kafka.stop();
     }