Kafka Producer拦截器

Kafka中的拦截器(Interceptor)是0.10.x.x版本引入的一个功能,一共有两种:Kafka Producer端的拦截器和Kafka Consumer端的拦截器。本篇主要讲述的是Kafka Producer端的拦截器,它主要用来对消息进行拦截或者修改,也能够用于Producer的Callback回调以前进行相应的预处理。apache 使用Kafka Producer端的拦截器很是简单
相关文章
相关标签/搜索