Kafka SimpleConsumer（低級用戶）使用案例/優勢

Question

只有SimpleConsumer API可以控制每個用戶從哪個分區檢索數據，據說它具有更好的偏移管理。有人能夠詳細解釋我在什麼情況下使用不太複雜的高級消費者需要這種細粒度控制。謝謝。

Answer 1

實際上，新的客戶API是簡單和高級API集合的完美組合。 seek（）和assign（）方法提供你提到的行爲。

無論哪種方式，一種情況涉及爲不同分區分配優先級：例如，分區0可能是低優先級消息，分區1可能具有高優先級消息。在這種情況下，您需要先使用來自分區1的消息，然後才能使用來自分區0的任何消息。在這種情況下，必須能夠指導Kafka從一個特定的分區讀取數據。

Answer 2

如果你想利用消費者行爲的完全控制：

• 無限重的經紀情況下的網絡通信問題，從一個特定的主題分區
• 你自己
• 讀取數據偏移量管理（以db爲單位存儲偏移量）
• 簡單性 - 它不關心其他消費者實例，因此不需要重新平衡。