We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0072574 commit cbca786Copy full SHA for cbca786
spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java
@@ -362,11 +362,12 @@ void shouldInstantiateIfNotInContainer() {
362
@Test
363
@SuppressWarnings("deprecation")
364
void shouldLogConsumerRecordMessage() {
365
- ListenerUtils.setLogOnlyMetadata(false);
+ ListenerUtils.setLogOnlyMetadata(true);
366
RetryTopicConfigurer.LoggingDltListenerHandlerMethod method =
367
new RetryTopicConfigurer.LoggingDltListenerHandlerMethod();
368
method.logMessage(consumerRecordMessage);
369
then(consumerRecordMessage).should().topic();
370
+ ListenerUtils.setLogOnlyMetadata(false);
371
}
372
373
0 commit comments