У меня есть тема, которая используется двумя группами потребителей. В теме 10 сообщений.
Приложение 1 (группа потребителей 1) завершило обработку сообщений из темы, и когда я описываю kafka-consumer-groups (с --group consumerGroup1), тогда оно правильно показывает CURRENT-OFFSET = 10 и LOG-END-OFFSET = 10 .
Теперь я запускаю приложение 2 (Группа потребителей 2), которое использует ту же тему. Это не обработка сообщений. Когда я описываю kafka-consumer-groups (с --group consumerGroup2), он неожиданно показывает CURRENT-OFFSET = 10 и LOG-END-OFFSET = 10.
В идеале этого не должно происходить, и kafka должен иметь возможность распознавать, что для группы потребителей 2 сообщения не обрабатываются, и он должен обрабатывать все сообщения.
Что здесь может быть не так.