diff --git a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java index 0034833d..4e4d4b10 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java @@ -362,11 +362,12 @@ class RetryTopicConfigurerTests { @Test @SuppressWarnings("deprecation") void shouldLogConsumerRecordMessage() { - ListenerUtils.setLogOnlyMetadata(false); + ListenerUtils.setLogOnlyMetadata(true); RetryTopicConfigurer.LoggingDltListenerHandlerMethod method = new RetryTopicConfigurer.LoggingDltListenerHandlerMethod(); method.logMessage(consumerRecordMessage); then(consumerRecordMessage).should().topic(); + ListenerUtils.setLogOnlyMetadata(false); } @Test