From 52e65d804f7a9e501a8c50955669dc8e921ef966 Mon Sep 17 00:00:00 2001 From: Stanislav Kozlovski Date: Fri, 13 Sep 2019 14:41:46 -0500 Subject: [PATCH] KAFKA-8894: Bump streams test topic deletion assertion timeout from 30s to 60s We have seen rare flakiness in this assertion - all of streams' internal topics would not get deleted within the 30 second window. Increasing to 60 seconds should reduce the occurrence. --- .../streams/integration/AbstractResetIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java index 675286bd259c8..b49c66ae6371a 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java @@ -583,10 +583,10 @@ private void cleanGlobal(final boolean withIntermediateTopics, private void assertInternalTopicsGotDeleted(final String intermediateUserTopic) throws Exception { // do not use list topics request, but read from the embedded cluster's zookeeper path directly to confirm if (intermediateUserTopic != null) { - cluster.waitForRemainingTopics(30000, INPUT_TOPIC, OUTPUT_TOPIC, OUTPUT_TOPIC_2, OUTPUT_TOPIC_2_RERUN, + cluster.waitForRemainingTopics(60000, INPUT_TOPIC, OUTPUT_TOPIC, OUTPUT_TOPIC_2, OUTPUT_TOPIC_2_RERUN, Topic.GROUP_METADATA_TOPIC_NAME, intermediateUserTopic); } else { - cluster.waitForRemainingTopics(30000, INPUT_TOPIC, OUTPUT_TOPIC, OUTPUT_TOPIC_2, OUTPUT_TOPIC_2_RERUN, + cluster.waitForRemainingTopics(60000, INPUT_TOPIC, OUTPUT_TOPIC, OUTPUT_TOPIC_2, OUTPUT_TOPIC_2_RERUN, Topic.GROUP_METADATA_TOPIC_NAME); } }