[ https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Philip Nee updated KAFKA-15942: ------------------------------- Labels: consumer-threading-refactor (was: ) > Implement ConsumerInterceptor > ----------------------------- > > Key: KAFKA-15942 > URL: https://issues.apache.org/jira/browse/KAFKA-15942 > Project: Kafka > Issue Type: Sub-task > Components: consumer > Reporter: Philip Nee > Priority: Major > Labels: consumer-threading-refactor > > 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)