【问题标题】:Kafka consumer doesn't receive messages until restarted卡夫卡消费者在重新启动之前不会收到消息
【发布时间】:2015-11-29 22:59:42
【问题描述】:

我已经尝试过 Kafka 0.8.2.2 和 0.9.0.0 并且在两者上都看到了相同的问题,即:

我启动一个新的 Zookeeper 和 Kafka 服务器(空数据/日志目录),启动“mytopic”的消费者进程,启动“mytopic”的生产者进程,然后通过生产者发送消息。 消费者在重新启动之前不会收到消息。

我尝试使用“最早”和“最新”的消费者偏移重置策略来配置消费者。

我的问题是 - 这是预期的行为吗?如果是这样,有没有办法改变它。如果不是,这是怎么回事?

【问题讨论】:

  • 你能分享你提供的命令或任何代码吗?
  • 您是否使用命令行客户端来启动生产者和消费者?您在什么时候开始创建主题的生产者和消费者?
  • 有趣的问题。但需要更多细节。
  • @morganw09dev 我正在使用新的 Kafka 消费者和生产者库 (0.9),并允许自动创建主题。
  • 您使用的是 Python 还是 Java Kafka 消费者?

标签: apache-kafka


【解决方案1】:

如果您首先使用尚不存在但将由 Kafka 代理自动创建的主题启动消费者,这可能与 this question 中的行为相同。您可以试试那里提到的解决方案是否解决了您的问题?

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2020-07-24
    • 1970-01-01
    • 2016-10-26
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-01-26
    • 1970-01-01
    相关资源
    最近更新 更多