kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ableegold...@apache.org
Subject [kafka] branch 3.0 updated: MINOR: Increase the Kafka shutdown timeout to 120 (#11183)
Date Thu, 05 Aug 2021 22:31:41 GMT
This is an automated email from the ASF dual-hosted git repository.

ableegoldman pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 8db3bc2  MINOR: Increase the Kafka shutdown timeout to 120 (#11183)
8db3bc2 is described below

commit 8db3bc2cbd9b8f8aa9ad7c0a8ec40328161bbee1
Author: Zara Lim <jzaralim@gmail.com>
AuthorDate: Thu Aug 5 15:26:10 2021 -0700

    MINOR: Increase the Kafka shutdown timeout to 120 (#11183)
    
    The streams static membership test has failed several times due to hitting the Kafka shutdown
timeout, but the logs were showing that the shutdown did actually succeed after the 60 second
timeout.
    
    Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>, Walker Carlson <wcarlson@confluent.io>
---
 tests/kafkatest/tests/streams/streams_static_membership_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/kafkatest/tests/streams/streams_static_membership_test.py b/tests/kafkatest/tests/streams/streams_static_membership_test.py
index f31c38a..5838484 100644
--- a/tests/kafkatest/tests/streams/streams_static_membership_test.py
+++ b/tests/kafkatest/tests/streams/streams_static_membership_test.py
@@ -96,7 +96,7 @@ class StreamsStaticMembershipTest(Test):
         stop_processors(processors, self.stopped_message)
 
         self.producer.stop()
-        self.kafka.stop()
+        self.kafka.stop(timeout_sec=120)
         self.zookeeper.stop()
 
     def verify_processing(self, processors):

Mime
View raw message