【发布时间】: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