Kafka producer拦截器与 Stream

Kafka producer拦截器(interceptor) 1 拦截器原理 Producer拦截器(interceptor)是在Kafka 0.10版本被引入的,主要用于实现clients端的定制化控制逻辑。java 对于producer而言,interceptor使得用户在消息发送前以及producer回调逻辑前有机会对消息作一些定制化需求,好比修改消息等。同时,producer容许用户指定多
相关文章
相关标签/搜索