黑猴子的家：Kafka 拦截器应用案例

Code -> GitHub https://github.com/liufengji/kafka_api.git 1、需求 实现一个简单的双interceptor组成的拦截链。 第一个interceptor会在消息发送前将时间戳信息加到消息value的最前部； 第二个interceptor会在消息发送后更新成功发送消息数或失败发送消息数。 2、拦截器一 增加时间戳拦截器 import java.

>>阅读原文<<