ProducerInterceptor

ProducerInterceptor精品文章

• 

  Kafka源码阅读日记——ProducerInterceptor

  ... } } }); 拦截器(ProducerInterceptor) public interface ProducerInterceptor extends Configurable { /** * 消息发送前调用 */ public ProducerRecord ...

  Genng 2019-08-15 14:39 评论0 收藏0
• 

  源码分析Kafka之Producer

  ...适应不同的消息类型：比如有无分区、有无key等。 ①中ProducerInterceptors（有0 ~ 无穷多个，形成一个拦截链）对ProducerRecord进行拦截处理（比如打上时间戳，进行审计与统计等操作） public ProducerRecord onSend(ProducerRecord record) { Prod...

  BDEEFE 2019-08-19 11:01 评论0 收藏0