dajac commented on code in PR #13678:
URL: https://github.com/apache/kafka/pull/13678#discussion_r1221045241
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##########
@@ -105,6 +105,10 @@ public final class ConsumerCoordinator extends
AbstractCoordinator {
private final boolean autoCommitEnabled;
private final int autoCommitIntervalMs;
private final ConsumerInterceptors<?, ?> interceptors;
+ // track number of async commits for which callback must be called
+ // package private for testing
+ final AtomicInteger inFlightAsyncCommits;
+ // track number of inflight coordinator lookups
Review Comment:
nit: Could we say `track the number of pending async commits waiting on the
coordinator lookup to complete`.?
--
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
