From 02a17e1d57fc1e5d2d9bf4ea33e4d0baeb7b88c9 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 17 Dec 2024 14:02:22 -0500 Subject: [PATCH] Add `@LogLevels` to `KafkaDslTests` for more diagnostics --- .../springframework/integration/kafka/dsl/KafkaDslTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java index 12208d3de4..2116847504 100644 --- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java +++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java @@ -53,6 +53,7 @@ import org.springframework.integration.kafka.inbound.KafkaMessageSource; import org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler; import org.springframework.integration.kafka.support.KafkaIntegrationHeaders; import org.springframework.integration.support.MessageBuilder; +import org.springframework.integration.test.condition.LogLevels; import org.springframework.integration.test.util.TestUtils; import org.springframework.kafka.annotation.EnableKafka; import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; @@ -98,6 +99,7 @@ import static org.assertj.core.api.Assertions.assertThat; */ @SpringJUnitConfig @DirtiesContext +@LogLevels(level = "debug", categories = "org.apache.kafka.clients.consumer") public class KafkaDslTests { private static final Log log = LogFactory.getLog(KafkaDslTests.class);