Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add @LogLevels to KafkaDslTests for more diagnostics

Browse Source
This commit is contained in:
Artem Bilan
2024-12-17 14:02:22 -05:00
parent af4277e2f4
commit 02a17e1d57
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
View File

@@ -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);