[ https://issues.apache.org/jira/browse/KAFKA-18065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17900287#comment-17900287 ]
Peter Lee commented on KAFKA-18065: ----------------------------------- Hi [~chia7712] I think this has been finished, see below links: 1. [ClassicKafkaConsumer#acquire|https://github.com/peterxcli/kafka/blob/38aca3a045474a9e52ae25bde28d8a013b04f92b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java#L1222-L1231] 2. [AsyncKafkaConsumer#acquire|https://github.com/peterxcli/kafka/blob/38aca3a045474a9e52ae25bde28d8a013b04f92b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L1826-L1835] 3. [ShareConsumerImpl#acquire|https://github.com/peterxcli/kafka/blob/38aca3a045474a9e52ae25bde28d8a013b04f92b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java#L924-L937] > be helpful when throwing ConcurrentModificationException out of consumers > ------------------------------------------------------------------------- > > Key: KAFKA-18065 > URL: https://issues.apache.org/jira/browse/KAFKA-18065 > Project: Kafka > Issue Type: Improvement > Reporter: Chia-Ping Tsai > Assignee: Chia-Ping Tsai > Priority: Minor > > from https://github.com/apache/kafka/pull/8193 -- This message was sent by Atlassian Jira (v8.20.10#820010)