黑猴子的家：Kafka 攔截器應用案例

Code -> GitHub https://github.com/liufengji/kafka_api.git 1、需求 實現一個簡單的雙interceptor組成的攔截鏈。 第一個interceptor會在消息發送前將時間戳信息加到消息value的最前部； 第二個interceptor會在消息發送後更新成功發送消息數或失敗發送消息數。 2、攔截器一 增加時間戳攔截器 import java.

>>阅读原文<<