5.kafka拦截器
拦截器定义
拦截器参数命名为：interceptor.classes。官方文档解析如下：
即拦截发送到kafka服务器之前的消息，且在序列化&反序列化之前调用，序列化&反序列化又在分区策略之前调用，这个调用顺序在[kafka生产者&消费者]已经分析过了。拦截器允许修改key和value，同时拦截器可以指定多个，多个拦截器形成拦截器链，且有先后顺序，假定按照如下方式配置2个拦截器，那么会先调用AProducerInterceptor，再调用BProducerInterceptor，且调用BProducerInterceptor时的ProducerRecord是经过AProducerInterceptor修改过的ProducerRecord（如果在AProducerInterceptor中修改过ProducerRecord的话）：
源码解读
自定义实现
- 发表于:
- 原文链接：https://kuaibao.qq.com/s/20180802G00HHF00?refer=cp_1026
- 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号（企鹅号）传播渠道之一，根据《腾讯内容开放平台服务协议》转载发布内容。
- 如有侵权，请联系 cloudcommunity@tencent.com 删除。
相关快讯
扫码
添加站长 进交流群
领取专属 10元无门槛券
私享最新 技术干货
腾讯云开发者
