ProducerInterceptor精品文章

• 

  Kafka源碼閱讀日記——ProducerInterceptor

  ... } } }); 攔截器(ProducerInterceptor) public interface ProducerInterceptor extends Configurable { /** * 消息發(fā)送前調(diào)用 */ public ProducerRecord ...

  Genng 2019-08-15 14:39 評(píng)論0 收藏0
• 

  源碼分析Kafka之Producer

  ...適應(yīng)不同的消息類型：比如有無分區(qū)、有無key等。 ①中ProducerInterceptors（有0 ~ 無窮多個(gè)，形成一個(gè)攔截鏈）對(duì)ProducerRecord進(jìn)行攔截處理（比如打上時(shí)間戳，進(jìn)行審計(jì)與統(tǒng)計(jì)等操作） public ProducerRecord onSend(ProducerRecord record) { Prod...

  BDEEFE 2019-08-19 11:01 評(píng)論0 收藏0