Skip to content

Commit df92ec5

Browse files
committed
Fix Race in Tests
1 parent febd8ee commit df92ec5

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -919,7 +919,7 @@ public void testNonResponsiveConsumerEventNotIssuedWithActiveConsumer() throws E
919919
TopicPartitionOffset[] topicPartition = new TopicPartitionOffset[] {
920920
new TopicPartitionOffset("foo", 0) };
921921
ContainerProperties containerProps = new ContainerProperties(topicPartition);
922-
containerProps.setNoPollThreshold(2.0f);
922+
containerProps.setNoPollThreshold(5.0f);
923923
containerProps.setPollTimeout(100);
924924
containerProps.setMonitorInterval(1);
925925
containerProps.setMessageListener(mock(MessageListener.class));

0 commit comments

Comments
 (0)