[ https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kirk True updated KAFKA-15942: ------------------------------ Parent: (was: KAFKA-14246) Issue Type: New Feature (was: Sub-task) > Implement ConsumerInterceptor > ----------------------------- > > Key: KAFKA-15942 > URL: https://issues.apache.org/jira/browse/KAFKA-15942 > Project: Kafka > Issue Type: New Feature > Components: clients, consumer > Reporter: Philip Nee > Assignee: Lucas Brutschy > Priority: Major > Labels: consumer-threading-refactor > Fix For: 3.8.0 > > > As title, we need to implement ConsumerInterceptor in the AsyncKafkaConsumer > > This is the current code. The implementation would be very similar > {code:java} > if (interceptors != null) > interceptors.onCommit(offsets); {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)