sunm2n opened a new pull request, #23720: URL: https://github.com/apache/kafka/pull/23720
The classic protocol case of ColdStartStickinessIntegrationTest takes about 73 seconds locally, while the streams protocol case takes about 23 seconds. After the first phase, the test closes both instances and waits for the group to become empty before the cold restart. With the classic protocol, the stream threads stay in the group on close, so the group only becomes empty when both members are removed on heartbeat expiration, about 44 seconds after the close. The streams protocol case is not affected, because dynamic members leave the group on close by default. This closes the first-phase instances with LEAVE_GROUP, as #23600 did for JoinGracePeriodDurabilityIntegrationTest, and keeps the original 60 second close timeout. The test still waits for the group to become empty before the cold restart, and the existing assertion that no records are restored passes with both protocols. Local runs on the same machine: | | Before (2 runs) | After (2 runs) | |---|---|---| | classic | 72.8s, 72.9s | 28.8s, 29.0s | | streams | 23.6s, 22.6s | 23.3s, 23.6s | Both protocol cases passed in each run. -- 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]
