frankvicky commented on code in PR #23109:
URL: https://github.com/apache/kafka/pull/23109#discussion_r4378727149
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##########
@@ -2433,7 +2433,7 @@ boolean processBackgroundEvents(boolean
skipAssignmentEvents) {
* As an example, take {@link #unsubscribe()}. To start unsubscribing, the
application thread enqueues an
* {@link UnsubscribeEvent} on the application event queue. That event
will eventually trigger the
* rebalancing logic in the background thread. Critically, as part of this
rebalancing work, the
- * {@link ConsumerRebalanceListener#onPartitionsRevoked(Collection)}
callback needs to be invoked for any
+ * {@link RebalanceListener#onPartitionsRevoked(Collection,
RebalanceConsumer)} callback needs to be invoked for any
Review Comment:
I think we could file a jira for this.
Could you please open a jira ticket?
--
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]
