Название группы не опрашивает данные

Question

У меня есть тема с сообщениями, и есть потребитель с именем группы как "KafkaConsumerExample".когда я перезапускаю потребителя, все сообщения из темы были получены без проблем.но когда я изменяю имя своей группы потребителей с тем же кодом, потребитель не получает данные из темы?Что было бы причиной этой проблемы, изменение имени потребителя меняет поведение от темы.не могли бы вы помочь здесь?

Answer 1

Проблема, с которой вы сталкиваетесь, заключается в том, что при использовании новой группы потребителей для чтения темы первые прочитанные сообщения происходят сразу после сообщений, уже прочитанных какой-либо другой группой потребителей (см. auto.offset.reset). объяснение). Это свойство конфигурации потребителя позволяет начать чтение с самого последнего смещения (по умолчанию, поэтому вы можете начать примерно с того места, где остановились другие группы), но вы хотите установить это свойство как "самое раннее", чтобы заставить потребителя читать из первого сообщения в каждом разделе.

Answer 2

Вы не можете снова использовать сообщения, используя то же имя группы потребителей. Это потому, что kafka поддерживает смещения для ведения журналов данных, которые она использовала. Это обеспечивает ровную семантику кафки.

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

Надеюсь, это поможет! дайте мне знать, если я отвечу на ваш вопрос или есть что-нибудь еще?