adikou opened a new pull request, #22270: URL: https://github.com/apache/kafka/pull/22270
New public interface providing a restricted Consumer view for use during rebalance callbacks. DelegatingRebalanceConsumer implements this with lifecycle enforcement (throws IllegalStateException after callback returns). ConsumerAwareRebalanceListener wraps a user listener and manages the delegate lifecycle per invocation. ConsumerRebalanceListener gets 2-arg default method variants that receive the restricted view -- 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]
