最近在StackOverflow碰到的一個問題，即在consumer.poll之后assignment()返回為空的問題，如下面這段代碼所示： 有意思的是，如果是consumer.po ...

一、含義 CommitFailedException異常：位移提交失敗時候拋出的異常。通常該異常被拋出時還會攜帶這樣的一段話： Commit cannot be completed sinc ...

上一篇《Kafka Consumer多線程實例續篇》修正了多線程提交位移的問題，但依然可能出現數據丟失的情況，原因在於多個線程可能拿到相同分區的數據，而消費的順序會破壞消息本身在分區中的順序，因而擾亂 ...

　　在上一篇《Kafka Consumer多線程實例》中我們討論了KafkaConsumer多線程的兩種寫法：多KafkaConsumer多線程以及單KafkaConsumer多線程。在第二種用法中我 ...

　　本文闡述如何使用Kafka自帶的kafka-consumer-groups.sh腳本隨意設置消費者組(consumer group)的位移。需要特別強調的是， 這是0.11.0.0版本提供的新功能 ...

Kafka 2.6引入的新功能：消費者能夠主動觸發Rebalance。一直以來，Rebalance的觸發都是由Coordinator來執行的，但有些場景下消費者端能夠主動觸發Rebalance會很有必 ...

碰到了有人問起這個問題，目前java consumer沒有利用OffsetAndMetadata中的metadata字段記錄提交的時間，故直接通過java consumer來查詢是不行，我們需要直接讀 ...

Kafka 2.3發布后官網的Consumer參數中增加了一個新的參數：group.instance.id。下面是這個參數的解釋： A unique identifier of the con ...