Потребитель Kafka Java не использует сообщения из определенного раздела - PullRequest
0 голосов
/ 21 февраля 2019

Я создал тему с 5 разделами с 3 коэффициентами репликации. У меня запущены два потребительских приложения, оба принадлежат к разной потребительской группе.У меня есть один продюсер, который создает сообщения на эту тему.Ниже приведен скриншот статуса раздела, лидера и реплик для topic.min.insync.replicas, который имеет конфигурацию по умолчанию.enter image description here

Первоначально оба потребителя потребляют сообщения из всех разделов, но через некоторое время сообщения потребляются только из раздела 2. Если я удаляю тему и создаю заново, сообщения будутбыть истребленным со всех сторон.Я сталкиваюсь с этой проблемой очень часто.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...