Philip Nee created KAFKA-15942:
----------------------------------
Summary: Implement ConsumerInterceptor
Key: KAFKA-15942
URL: https://issues.apache.org/jira/browse/KAFKA-15942
Project: Kafka
Issue Type: Improvement
Components: consumer
Reporter: Philip Nee
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)
