Skip to content

Commit 0589bea

Browse files
committed
GH-642: Increase test timeout
Fixes #642
1 parent b4a374c commit 0589bea

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2016-2017 the original author or authors.
2+
* Copyright 2016-2018 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -579,7 +579,7 @@ private void testAckOnErrorWithManualImmediateGuts(String topic, boolean ackOnEr
579579

580580
// only one message should be acknowledged, because second, starting with "b"
581581
// will throw RuntimeException and acknowledge() method will not invoke on it
582-
for (int i = 0; i < 100; i++) {
582+
for (int i = 0; i < 300; i++) {
583583
if (consumer.position(new TopicPartition(topic, 0)) == 1) {
584584
break;
585585
}

0 commit comments

Comments
 (0)