lucliu1108 opened a new pull request, #23138: URL: https://github.com/apache/kafka/pull/23138
## Summary This PR adds 3 more system test scenarios for streams topology test. 1. `test_topology_description_not_resolicited_after_client_restart`: client start with description already stored, the broker is already running -> client restarted and since `storedDescriptionTopologyEpoch == currentTopologyEpoch`, the broker does not solicit again. 2. `test_topology_description_only_one_member_pushes`: two members join the same streams group at the same time and both heartbeat to the broker -> since `StreamsGroupTopologyDescriptionBackoff.armIfNotActive`'s check-and-arm on the group's back-off entry is atomic, only one member's heartbeat gets `TopologyDescriptionRequired=true`; the other member never sends a push. 3. `test_topology_description_resolicited_after_group_delete_and_recreate`: client pushes successfully, then the group is stopped and deleted -> a new client joins under the same application.id and since the delete clears the old group's `storedDescriptionTopologyEpoch`, the broker treats it as a brand-new group and solicits again. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
