步骤1:创建只有一个分区的主题: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
第2步:产生一些消息到主题 test
.
第三步:开始主题消费 test
. 它可以获取步骤2中推送的所有消息。
它适用于具有1个分区的主题。
但是当我尝试将topic与2个分区一起使用时,使用者只会得到在使用者启动后生成的消息。
复制:
步骤1:创建只有一个分区的主题: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
第2步:产生一些消息到主题 test2
.
第三步:让消费者开始讨论这个主题 test2
. 它无法在步骤2中获取消息。
第四步:让消费者继续关注,向主题传递一些信息 test2
,那么现在消费者可以获得消息。
效果好吗?或者我错过了什么?
1条答案
按热度按时间zbdgwd5y1#
auto.offset.reset选项的默认值为“latest”
如果要读取在使用者设置auto.offset之前发送的消息。reset:earliest