mjsax opened a new pull request, #23322: URL: https://github.com/apache/kafka/pull/23322
The refiner is a static no-op today, so no broker ever hands out a warm-up task and the client-side warm-up handling has no end-to-end coverage. Turn AssignmentRefiner into an interface with a NoOp default and let an internal, undocumented broker config (group.streams.assignment.refiner.class) select an implementation, so a test can put a real warm-up assignment in front of a real client. With the config unset, behavior is unchanged. The refiner is also no longer called with a topology that is not configured yet: the isReady() check in the heartbeat path guards only the task-ID validation, so any refiner that reads subtopologies() to tell a stateful task from a stateless one would have thrown. The identity refiner masked this. -- 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]
