流動消費者如何在節點rdkafka中工作

Question

我正在使用流動模式消費者rdkafka與我的節點應用程序。我一次只想獲取幾條消息。它是否繼續提取消息並將它們緩衝在隊列中？如果是的話，那麼我們可以改變這個配置並且限制獲取的消息數量嗎？

Answer 1

我不確定rdkafka，但在java客戶端有一個配置，以限制沒有。在一次輪詢操作中獲取的記錄數量。

max.poll.records的最大記錄數返回單一調用poll（）

Answer 2

是，消費者獲取信息到一個隊列，直至排隊的消息達到一定的限制。

嘗試在你的消費者的配置使用此屬性：

{ 
    //... 
    'queued.max.messages.kbytes': 1024 
    //Maximum number of kilobytes per topic + partition in the local consumer queue 
    //... 
} 

此屬性記錄here