Skip to content

Commit 398967f

Browse files
committed
Fix KafkaMessageListenerContainerTests
https://build.spring.io/browse/SK-SK13X-67
1 parent 8a83135 commit 398967f

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/KafkaMessageListenerContainerTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1402,7 +1402,7 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
14021402
public void testAckModeCount() throws Exception {
14031403
ConsumerFactory<Integer, String> cf = mock(ConsumerFactory.class);
14041404
Consumer<Integer, String> consumer = mock(Consumer.class);
1405-
given(cf.createConsumer(isNull(), eq("clientId"))).willReturn(consumer);
1405+
given(cf.createConsumer(anyString(), eq("clientId"))).willReturn(consumer);
14061406
TopicPartition topicPartition = new TopicPartition("foo", 0);
14071407
final Map<TopicPartition, List<ConsumerRecord<Integer, String>>> records1 = new HashMap<>();
14081408
records1.put(topicPartition, Arrays.asList(

0 commit comments

Comments
 (0)