From e5f4f6bf0e397981c1e6830035c71757a6950ae0 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 4 Apr 2018 11:34:15 -0400 Subject: [PATCH] GH-642: Increase test timeout Fixes https://github.com/spring-projects/spring-kafka/issues/642 --- .../listener/ConcurrentMessageListenerContainerTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java index 8514d3aa53..f0d0b925ae 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 the original author or authors. + * Copyright 2016-2018 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -587,7 +587,7 @@ private void testAckOnErrorWithManualImmediateGuts(String topic, boolean ackOnEr // only one message should be acknowledged, because second, starting with "b" // will throw RunTimeException and acknowledge() method will not invoke on it - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 300; i++) { if (consumer.position(new TopicPartition(topic, 0)) == 1) { break; }