卡夫卡消费者无法获得先前未消费的事件

Question

步骤1:只使用一个分区创建主题：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

步骤2:向主题test生成一些消息。

步骤3:开始使用主题test。它可以获取步骤2中推送的所有消息。

它可以很好的工作与主题与一个分区。

但是，当我尝试在两个分区中使用主题时，使用者只会获得在使用者结束后生成的消息。

复制：

步骤1:只使用一个分区创建主题：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2

步骤2:向主题test2生成一些消息。

步骤3:启动主题test2上的使用者。它无法在步骤2中获得消息。

步骤4:让使用者继续，生成一些消息给主题test2，然后消费者就可以得到消息了。

它正常工作吗？还是我错过了什么？

Answer 1

auto.offset.reset选项的默认值是“最新”

如果您想读取在使用者设置auto.offset.reset:earliest之前发送的消息