企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# 客户端高级功能 ## Kafka 拦截器 * 拦截器基本思想 * 允许应用程序不修改逻辑的情况下,动态地实现一组可插拔的事件处理逻辑链 * e.g. Spring Interceptor, Apache Flume ![](https://img.kancloud.cn/09/68/096831a3ba037b3f9e507e6db631d3c4_770x461.png) * Kafka 拦截器 * 生产者拦截器 * 允许你在发送消息前、消息提交成功后植入拦截器逻辑 * 消费者拦截器 * 消费消息前、提交位移后编写拦截器逻辑 * 这两种拦截器都支持链的方式 ## Kafka 拦截器使用场景 * 客户端监控 * 端到端系统性能检测 * 消息审计