Add @LogLevels to KafkaDslTests for more diagnostics

spring-projects · Dec 17, 2024 · 02a17e1 · 02a17e1
1 parent af4277e
commit 02a17e1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...egration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java b/...egration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
@@ -53,6 +53,7 @@
 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 @@
  */
 @SpringJUnitConfig
 @DirtiesContext
+@LogLevels(level = "debug", categories = "org.apache.kafka.clients.consumer")
 public class KafkaDslTests {
 
 	private static final Log log = LogFactory.getLog(KafkaDslTests.class);