You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by GitBox <gi...@apache.org> on 2020/11/12 08:53:20 UTC
[GitHub] [kafka] feyman2016 opened a new pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
feyman2016 opened a new pull request #9588:
URL: https://github.com/apache/kafka/pull/9588
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [kafka] feyman2016 edited a comment on pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
Posted by GitBox <gi...@apache.org>.
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:
users@infra.apache.org
[GitHub] [kafka] feyman2016 commented on pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
Posted by GitBox <gi...@apache.org>.
feyman2016 commented 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.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [kafka] feyman2016 edited a comment on pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
Posted by GitBox <gi...@apache.org>.
feyman2016 edited a comment on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-726134837
Call for review @abbccdda :)
The failed test: `org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization` doesn't seem related, local run succeeded.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [kafka] abbccdda merged pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
Posted by GitBox <gi...@apache.org>.
abbccdda merged pull request #9588:
URL: https://github.com/apache/kafka/pull/9588
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [kafka] feyman2016 commented on pull request #9588: KAFKA-10699: Add system test coverage for group coordinator migration
Posted by GitBox <gi...@apache.org>.
feyman2016 commented on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-726134837
The failed test: `org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization` doesn't seem related, local run succeeded.
----------------------------------------------------------------
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:
users@infra.apache.org