squah-confluent opened a new pull request, #22277: URL: https://github.com/apache/kafka/pull/22277
In testDynamicGroupConfig, we dynamically configure a group's streams.num.standby.replicas, followed by streams.task.offset.interval.ms. We then wait for the next assignment and check that it has the expected number of standby replicas and expected task offset interval. However, this only guarantees that the new streams.num.standby.replicas config has propagated to the group coordinator and not necessarily the new task offset interval. Add a loop to heartbeat until we observe the expected task offset interval or a timeout elapses. -- 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]
