[camel-quarkus] 05/05: Forward Kafka testcontainer's log to stdout to see why it is sometimes failing #2461

[pp...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ppalaga pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 711a3177791ee4c201729cbb70111cbd45a08e46
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Fri Apr 9 17:29:56 2021 +0200

    Forward Kafka testcontainer's log to stdout to see why it is sometimes failing #2461
---
 .../apache/camel/quarkus/component/kafka/it/CamelKafkaTestResource.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaTestResource.java b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaTestResource.java
index d5a8570..fd347c4 100644
--- a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaTestResource.java
+++ b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaTestResource.java
@@ -40,6 +40,8 @@ public class CamelKafkaTestResource implements ContainerResourceLifecycleManager
         try {
             DockerImageName imageName = DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION);
             container = new KafkaContainer(imageName)
+                    /* Added container startup logging because of https://github.com/apache/camel-quarkus/issues/2461 */
+                    .withLogConsumer(frame -> System.out.print(frame.getUtf8String()))
                     .withEmbeddedZookeeper()
                     .waitingFor(Wait.forListeningPort());