[kafka] branch 3.0 updated: MINOR: Increase the Kafka shutdown timeout to 120 (#11183)

[ab...@apache.org]

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 <jz...@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 <ab...@apache.org>, Walker Carlson <wc...@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):