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 <jzara...@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 <ableegold...@apache.org>, Walker
Carlson <wcarl...@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):
