我正在使用 queuedchunks.max 属性一次从主题中检索 10 条消息，但它返回了所有可用的消息（超过 10 条）。如果有办法只检索所需的消息，请告诉我。
问问题
2270 次
2 回答
0
听起来你正在寻找max.poll.records.
如果您想使用少于默认数量的记录，您可以手动在应用程序中添加一个计数器，然后在看到这么多消息时中断循环。
于 2018-11-17T02:48:56.807 回答
-2
此链接可能会帮助您理解。
请按照kafka-configuration中所示设置batch.size的值，以一次从一个主题获取 10 条消息。
于 2013-02-03T16:36:15.317 回答