【问题标题】:Consume only first message from Kafka Queue?仅使用来自 Kafka 队列的第一条消息?
【发布时间】:2016-11-09 01:31:49
【问题描述】:

有没有办法只使用 1000 条消息中来自 kafka 队列的第一条消息?我正在尝试在 java 中实现相同的功能。而且我没有任何后端数据库。

【问题讨论】:

  • 如果你只想消费第一条消息,那么Kafka不是正确的选择。您应该已经解释了您的用例。

标签: apache-kafka


【解决方案1】:

现在你做不到,有KIP-41可以解决这个问题。

虽然如果你知道你想要的元素的大小,你可以在消费者中设置一个名为 fetch.message.max.bytes 的属性 到您要投票的元素的大小,每次投票将只返回一条记录。

【讨论】:

    猜你喜欢
    • 2017-04-18
    • 2023-03-14
    • 2013-09-23
    • 2016-04-24
    • 1970-01-01
    • 1970-01-01
    • 2017-04-17
    • 2018-12-31
    • 2019-09-01
    相关资源
    最近更新 更多