【发布时间】:2016-11-09 01:31:49
【问题描述】:
有没有办法只使用 1000 条消息中来自 kafka 队列的第一条消息?我正在尝试在 java 中实现相同的功能。而且我没有任何后端数据库。
【问题讨论】:
-
如果你只想消费第一条消息,那么Kafka不是正确的选择。您应该已经解释了您的用例。
标签: apache-kafka
有没有办法只使用 1000 条消息中来自 kafka 队列的第一条消息?我正在尝试在 java 中实现相同的功能。而且我没有任何后端数据库。
【问题讨论】:
标签: apache-kafka
现在你做不到,有KIP-41可以解决这个问题。
虽然如果你知道你想要的元素的大小,你可以在消费者中设置一个名为 fetch.message.max.bytes 的属性 到您要投票的元素的大小,每次投票将只返回一条记录。
【讨论】: