smjn opened a new pull request, #22360: URL: https://github.com/apache/kafka/pull/22360
Sometimes the system test `PerformanceServiceTest` could fail with 0 records consumed by share consumer because the perf test command times out in 10 seconds (default) and the partition assignment might not have happened for the share member. This is because assignment does not happen until share partitions are initialized in the share coordinator which is dynamically loaded when the FindCoordinator request is sent. The share group state topic too is created by auto topic manager and is not present in a cold start cluster. Decreasing the share goup heartbeat interval solves the issue as more heartbeats get sent in the 10 second interval. Default heartbeat interval is 5 seconds so test times out before getting an assignment. -- 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]
