Kafka 拦截器分为生产者拦截器和消费者拦截器。
生产者拦截器允许你在发送消息前以及消息提交成功后植入你的拦截器逻辑;
而消费者拦截器支持在消费消息前以及提交位移后编写特定逻辑。
使用
当前 Kafka 拦截器的设置方法是通过参数配置完成
2021-03-23