dino2895 opened a new pull request, #23353: URL: https://github.com/apache/kafka/pull/23353
This PR moves consumption-specific local state from `run` into `consume`, where it is exclusively used. The change: - Reduces the `consume` parameter list. - Keeps the consumption counters close to the consumption loop. - Removes the redundant `joinStartMs` alias by reusing `startMs`. - Preserves the existing consumption, rebalance timing, and reporting behavior. This is a follow-up to: https://github.com/apache/kafka/pull/13215#discussion_r3927390720 ### Testing - `./gradlew tools:test --tests org.apache.kafka.tools.ConsumerPerformanceTest` - `./gradlew tools:spotlessCheck` -- 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]
