首页 > 解决方案 > 有没有办法在 Kafka ProducerRecord 被序列化后拦截它?

问题描述

的方法ProducerInterceptor文档onSend说:

这是从 KafkaProducer.send(ProducerRecord) 和 KafkaProducer.send(ProducerRecord, Callback) 方法调用的,在键和值被序列化并分配分区之前(如果在 ProducerRecord 中未指定分区)。

有没有办法ProducerRecord在键和值被序列化后拦截?

标签: apache-kafka

解决方案


推荐阅读