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

GH-2220: Fix Test After Back Port

Browse Source
This commit is contained in:
Gary Russell
2022-04-14 15:33:23 -04:00
parent 00725743b3
commit cbca786f15
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-kafka/src/test/java/org/springframework/kafka/retrytopic/RetryTopicConfigurerTests.java
View File

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