卡夫卡長輪詢

Question

我正在看卡夫卡實施低延遲消息隊列，我一直在讀關於消費者長輪詢。但是，沒有關於如何實際使用長輪詢的示例，或者您需要設置哪些選項才能啓用它。如何使用kafka java api啓用長輪詢？

Answer 1

您不必每次都說它，因爲它是卡夫卡消費者的默認行爲。您需要在配置中設置的是fetch.wait.max.ms。

兩個值都達到你想要什麼重要的：

• fetch.min.bytes：經紀人會等待這個數據量，以填補之前發送給消費者客戶端的響應。
• fetch.wait.max.ms：在向消費者客戶端發送響應之前，代理將等待這段時間，除非它有足夠的數據填充響應（fetch.message.max.bytes）

尋找更多的配置選項Kafka Consumer Configs

卡夫卡用戶郵件列表是這樣的問題一個也不錯的選擇。