Шаг 1: создать тему только с одним разделом:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Шаг 2: Создать сообщение к теме test.
Шаг 3: Начать потребление по теме test.Он может получать все сообщения, которые выдвигаются на шаге 2.
Он прекрасно работает с темой с 1 разделом.
Но когда я пытаюсь использовать тему с 2 разделами, потребитель получает только сообщения, которыегенерируется после того, как потребитель активирован.
Воспроизвести:
Шаг 1: создать тему только с одним разделом:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
Шаг 2: Создать сообщение к теме test2.
Шаг 3: Начать прием с темы test2.Он не может получать сообщения на шаге 2.
Шаг 4: держать потребителя включенным, выдавать какое-то сообщение в тему test2, тогда теперь потребитель может получать сообщения.
Работает нормально?Или я что-то пропустил?