kumarpritam863 opened a new pull request, #12622: URL: https://github.com/apache/kafka/pull/12622
In case of the revocation of partitions, the updation of "**partition count**" metrics is being done before updating the new set of assignments. "**invokePartitionsRevoked**" method of "**onJoinComplete**" function of "**ConsumerCoordinator**" class is being called before the " **subscriptions.assignFromSubscribed(assignedPartitions)**" of the same class. As a result of which the old assigned partition count is getting updated again and again even after future rebalances. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
