jonmcewen commented on pull request #11326:
URL: https://github.com/apache/kafka/pull/11326#issuecomment-931972073
Just checked my commit history and I had an earlier implementation like
```
// decrement the count for the partition for which the batch was
aborted, as the last message
// wasn't sent yet and partition() will be called again
Optional.ofNullable(topicCounterMap.get(topic)).ifPresent(counter ->
counter.decrementAndGet());
```
I'm pretty sure this didn't behave as desired when under load, hence the
queueing solution, but I can't remember the exact behavioural issue.
--
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
