Kafka消费者无法获取以前的未消费事件

ddarikpa  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(721)

步骤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 ,那么现在消费者可以获得消息。
效果好吗?或者我错过了什么?

zbdgwd5y

zbdgwd5y1#

auto.offset.reset选项的默认值为“latest”
如果要读取在使用者设置auto.offset之前发送的消息。reset:earliest

相关问题