基於kafka interceptor監控kafka client消息延遲、數量

kafka interceptor能夠攔截,所有kafka client接收或發送的消息, 基於這一點,我們可以在消息被攔截到時,進行消息統計以及相應的延時計算; 需要明白一個點 kafka在0.10.0版本, 開始支持每個record帶一個timestamp. KafkaProducer發送的record所帶有的ts比較特別, 你可以在創建ProducerRecord時,設置該record的時間

>>阅读原文<<