Page History

...

The main new interface required for produce-time interceptors is the abstract ProduceRequestInterceptor class. User-defined implementation implementations of this class would serve as the a container for the lightweight server-side logic that would get executed for every record received by a brokerrecord pre-processing. The class' processRecord method enables three basic types of operations:

...

Once a user-defined implementation of ProduceRequestInterceptor is compiled and added to the classpath of the Kafka host;s runtime, it could be registered as an interceptor with the help of three new broker-side config options:

...