如何檢索卡夫卡消息的特定計數主題

Question

我正在使用queuedchunks.max屬性一次檢索10個來自主題的消息，但它返回了所有可用消息（超過10個）。請讓我知道如果有是一種僅檢索所需信息的方法。

Answer 1

This link可能會幫助您理解。

請確定batch.size的值，如kafka-configuration所示，以一次從主題獲得10條消息。