在Kafka中，拦截器一共有两种。分别是生产者端的和消费者端的。本文介绍生产者端的拦截器
Kafka Producer拦截器
Kafka Producer拦截器（Interceptor）主要用于实现clients端的定制化控制逻辑。对于Producer而言，Interceptor使得用户在消息发送前以及Producer回调逻辑前有机会对消息做一些定制化需求，比如修改消息等。其中最常用的应该是用来实现对所有的消息header中放一些参数。
ProducerInterceptor
在kafka-client中，Intercetpor的实现接口是org.apache.kafka.clients.producer.ProducerInterceptor 用于生产者发送消息到broker之前对消息进行处理。
ProducerInterceptor接口包含4个方法
onSend 方法
Producer在消息序列化和分配分区之前会调用拦截器的这个方法。
一般来说最好不要修改消息ProducerRecord的topic、key以及partition等信息，如果要修改，也需确保对其有准确的判断，否则会与预想的效果出现偏差。修改key不仅会影响分区的计算，同样也会影响Broker端日志压缩（Log Compaction）的功能。
onAcknowledgement 方法
在消息被应答之前或消息发送失败时调用，优先于用户设定的Callback之前执行。
这个方法运行在Producer的IO线程中，所以这个方法里实现的代码逻辑越简单越好，否则会影响消息的发送速率。文章来源：https://www.toymoban.com/news/detail-595255.html
close 方法文章来源地址https://www.toymoban.com/news/detail-595255.html
到了这里，关于Kafka中的producer拦截器的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
