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