lucasbru commented on code in PR #14779:
URL: https://github.com/apache/kafka/pull/14779#discussion_r1395779149
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##########
@@ -1068,12 +1168,17 @@ public void onComplete(Map<TopicPartition,
OffsetAndMetadata> offsets, Exception
@Override
public boolean updateAssignmentMetadataIfNeeded(Timer timer) {
- backgroundEventProcessor.process();
+ acquireAndEnsureOpen();
Review Comment:
updateAssignmentMetadataIfNeeded does not check for concurrent modification
in the original consumer, but that looks like a bug to me.
--
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
