You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Philip Nee (Jira)" <ji...@apache.org> on 2023/11/29 17:15:00 UTC
[jira] [Created] (KAFKA-15942) Implement ConsumerInterceptor
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)