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 4c5399d commit ebbe5f0Copy full SHA for ebbe5f0
spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -435,7 +435,7 @@ public void publishEvent(ApplicationEvent event) {
435
public void testNonResponsiveConsumerEventNotIssuedWithActiveConsumer() throws Exception {
436
ConsumerFactory<Integer, String> cf = mock(ConsumerFactory.class);
437
Consumer<Integer, String> consumer = mock(Consumer.class);
438
- given(cf.createConsumer(anyString(), eq(""))).willReturn(consumer);
+ given(cf.createConsumer(anyString(), anyString())).willReturn(consumer);
439
ConsumerRecords records = new ConsumerRecords(Collections.emptyMap());
440
CountDownLatch latch = new CountDownLatch(20);
441
given(consumer.poll(anyLong())).willAnswer(i -> {
0 commit comments