We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b688311 commit 7bd19fdCopy full SHA for 7bd19fd
spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -652,7 +652,7 @@ public void testBrokerDownEvent() throws Exception {
652
public void testNonResponsiveConsumerEventNotIssuedWithActiveConsumer() throws Exception {
653
ConsumerFactory<Integer, String> cf = mock(ConsumerFactory.class);
654
Consumer<Integer, String> consumer = mock(Consumer.class);
655
- given(cf.createConsumer(isNull(), eq(""))).willReturn(consumer);
+ given(cf.createConsumer(isNull(), isNull())).willReturn(consumer);
656
ConsumerRecords records = new ConsumerRecords(Collections.emptyMap());
657
CountDownLatch latch = new CountDownLatch(20);
658
given(consumer.poll(anyLong())).willAnswer(i -> {
0 commit comments