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 }