如何从Kafka主题中检索特定数量的消息

Question

3

我正在使用queuedchunks.max属性，每次从主题中检索10条消息，但它返回了所有可用的消息（超过10条）。请告诉我是否有一种方法只检索所需的消息。

- user1710079

1

如果您发布一些代表性的代码，将会更容易让其他人帮助您。 - Steve Czetty

既然要消费kafka消息，你需要使用while循环一个个地获取每个消息，那为什么不在获取所需数量的消息后直接跳出循环呢？ - C4stor

2个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- OneCricketeer · Answer 1

看起来你正在寻找 max.poll.records。

如果你想消费少于默认数量的记录，你可以在你的应用程序中手动添加一个计数器，然后在看到那么多消息时中断循环。

- Shiva K · Answer 2

这个链接或许能帮助您理解。

请按照 kafka-configuration 中所示设置 batch.size 的值，以便每次从主题中获取10条消息。