DBZ-7557 Include Redis and RocketMQ logs into test log

debezium · Feb 27, 2024 · 4978fe8 · 4978fe8
1 parent b410379
commit 4978fe8
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/...erver-redis/src/test/java/io/debezium/server/redis/RedisTestResourceLifecycleManager.java b/...erver-redis/src/test/java/io/debezium/server/redis/RedisTestResourceLifecycleManager.java
@@ -9,13 +9,17 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
 
 import io.debezium.server.TestConfigSource;
 import io.debezium.util.Testing;
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 
 public class RedisTestResourceLifecycleManager implements QuarkusTestResourceLifecycleManager {
+    private static final Logger LOGGER = LoggerFactory.getLogger(RedisTestResourceLifecycleManager.class);
 
     static final String READY_MESSAGE = "Ready to accept connections";
     public static final int REDIS_PORT = 6379;
@@ -36,6 +40,7 @@ private static synchronized void start(boolean ignored) {
     @Override
     public Map<String, String> start() {
         start(true);
+        container.followOutput(new Slf4jLogConsumer(LOGGER));
         Testing.Files.delete(TestConfigSource.OFFSET_STORE_PATH);
         Testing.Files.createTestingFile(TestConfigSource.OFFSET_STORE_PATH);
 

diff --git a/debezium-server-rocketmq/src/test/java/io/debezium/server/rocketmq/RocketMqContainer.java b/debezium-server-rocketmq/src/test/java/io/debezium/server/rocketmq/RocketMqContainer.java
@@ -9,7 +9,10 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
 import org.testcontainers.utility.DockerImageName;
 
 import com.github.dockerjava.api.command.InspectContainerResponse;
@@ -20,6 +23,7 @@
  * rocketmq container
  */
 public class RocketMqContainer extends GenericContainer<RocketMqContainer> {
+    private static final Logger LOGGER = LoggerFactory.getLogger(RocketMqContainer.class);
 
     private static final String ROCKETMQ_VERSION = ContainerImageVersions.getStableVersion("apache/rocketmq", ContainerImageVersions.NUMBERS_ONLY_VERSION_REGEX_PATTERN);
     private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("apache/rocketmq:" + ROCKETMQ_VERSION);
@@ -43,6 +47,7 @@ protected void configure() {
     @Override
 
     protected void containerIsStarted(InspectContainerResponse containerInfo) {
+        followOutput(new Slf4jLogConsumer(LOGGER));
         List<String> updateBrokerConfigCommands = new ArrayList<>();
         updateBrokerConfigCommands.add(updateBrokerConfig("brokerIP1", getHost()));
         updateBrokerConfigCommands.add(updateBrokerConfig("listenPort", getMappedPort(BROKER_PORT)));