feyman2016 edited a comment on pull request #9588: URL: https://github.com/apache/kafka/pull/9588#issuecomment-725938758
Running without the fix in KAFKA-10284(https://github.com/apache/kafka/pull/9270), the `FencedInstanceIdException` will be thrown, details as below. Test log: ``` File "/opt/kafka-dev/tests/kafkatest/tests/client/consumer_test.py", line 255, in test_static_consumer_persist_after_rejoin self.rolling_bounce_brokers(consumer, num_bounces=1, clean_shutdown=True) File "/opt/kafka-dev/tests/kafkatest/tests/client/consumer_test.py", line 70, in rolling_bounce_brokers self.await_all_members(consumer) File "/opt/kafka-dev/tests/kafkatest/tests/verifiable_consumer_test.py", line 87, in await_all_members self.await_members(consumer, self.num_consumers) File "/opt/kafka-dev/tests/kafkatest/tests/verifiable_consumer_test.py", line 84, in await_members err_msg="Consumers failed to join in a reasonable amount of time") File "/usr/local/lib/python3.7/dist-packages/ducktape/utils/util.py", line 41, in wait_until raise TimeoutError(err_msg() if callable(err_msg) else err_msg) ducktape.errors.TimeoutError: Consumers failed to join in a reasonable amount of time ``` Consumer Log: ``` org.apache.kafka.common.errors.FencedInstanceIdException: The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id. ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
