[kafka] branch trunk updated: MINOR: revert back to 60s session timeout for static membership test (#11881)

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/trunk by this push:
     new f28a2ee918 MINOR: revert back to 60s session timeout for static 
membership test (#11881)
f28a2ee918 is described below

commit f28a2ee918423e402ad9ddca9451b973dddfc591
Author: Luke Chen <show...@gmail.com>
AuthorDate: Fri Apr 22 02:51:31 2022 +0800

    MINOR: revert back to 60s session timeout for static membership test 
(#11881)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 tests/kafkatest/services/streams.py | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/tests/kafkatest/services/streams.py 
b/tests/kafkatest/services/streams.py
index f4f6a6a04f..5dedc57916 100644
--- a/tests/kafkatest/services/streams.py
+++ b/tests/kafkatest/services/streams.py
@@ -690,10 +690,9 @@ class StaticMemberTestService(StreamsTestBaseService):
                       streams_property.KAFKA_SERVERS: 
self.kafka.bootstrap_servers(),
                       streams_property.NUM_THREADS: self.NUM_THREADS,
                       consumer_property.GROUP_INSTANCE_ID: 
self.GROUP_INSTANCE_ID,
-                      consumer_property.SESSION_TIMEOUT_MS: 60000,
+                      consumer_property.SESSION_TIMEOUT_MS: 60000, # set 
longer session timeout for static member test
                       'input.topic': self.INPUT_TOPIC,
-                      "acceptable.recovery.lag": "9223372036854775807", # 
enable a one-shot assignment
-                      "session.timeout.ms": "10000" # set back to 10s for 
tests. See KIP-735
+                      "acceptable.recovery.lag": "9223372036854775807" # 
enable a one-shot assignment
                       }