Я использую confluent-kafka-5.1.2 сервер.У меня есть kafka-node потребитель (autoCommit: true, который работает на каком-либо промежуточном сервере. Кажется, он застрял.
kafka-consumer-groups --bootstrap-server localhost:9092 --group staging-myAccount-testing --describe
Это говорит мне, что идентификатор группы застрял на CURRENT-OFFSET 1.
Я пытался использовать все данные с моего локального компьютера с тем же идентификатором группы, надеясь, что он обновит смещение, и тогда фактический потребитель сможет возобновить работу. Но это не сработало. Когда я запускаю своего локального потребителя,Я вижу, что раздел переназначен мне, и я могу использовать все данные. Приведенная выше команда kafka показывает CURRENT-OFFSET до последнего сообщения. Все хорошо!
После этого я закрыл свой локальный потребитель и разделпереназначается фактическому потребителю (как видно по команде). Но теперь CURRENT-OFFSET снова устанавливается на 1. Иногда смещение сбрасывается только тогда, когда я создаю что-то в теме.
Iпрочитал эту ссылку, показывающую проблему, когда раздел назначается вместо подписки. Такие вещи, как смещения потребителей, перезаписываются, но я все еще не могу связать их с моей проблемой.