Skip to content

Commit 55ff86a

Browse files
committed
Fix ConcMLCMockTests for current RecInterceptor
1 parent 19a9a45 commit 55ff86a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerMockTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -691,7 +691,7 @@ void testInterceptInTxNonKafkaTM() throws InterruptedException {
691691

692692
@Override
693693
@Nullable
694-
public ConsumerRecord intercept(ConsumerRecord rec, Consumer consumer) {
694+
public ConsumerRecord intercept(ConsumerRecord rec) {
695695
order.add("interceptor");
696696
latch.get().countDown();
697697
return rec;

0 commit comments

Comments
 (0)