День добрый! Кто-нибдь сталкивался с таким багом: делаю —reset-offset

консьюмер группе на —to-latest. Отрабатывает без ошибок и выводит NEW-OFFSET по партициям равный последнему офсету. Но потом если сделать —describe, то в CURRENT-OFFSET старый, до ресета.

В логах кафки ошибок нет... куда копать?

Указать опцию —execute

а без нее и не работает

Работает. Выводит просто план. Как в вашем примере.

перепроверил. опция есть. I have no name!@kafka:/$ kafka-consumer-groups.sh --bootstrap-server kafka0:9093 --group cg1 --topic topic1 --reset-offsets -to-latest --execute --command-config=/tmp/consumer.properties GROUP TOPIC PARTITION NEW-OFFSET cg1 topic1 61 429807310 cg1 topic1 31 418914162 cg1 topic1 27 428231040 cg1 topic1 117 407786785 I have no name!@kafka:/$ kafka-consumer-groups.sh --bootstrap-server kafka0:9093 --group cg1 --describe --command-config=/tmp/consumer.properties Consumer group 'cg1 ' has no active members. GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID cg1 topic1 61 395218090 429809054 34590964 - - - cg1 topic1 31 385660700 418917682 33256982 - - - cg1 topic1 27 393577986 428234190 34656204 - - - cg1 topic1 117 375535921 407788843 32252922 - - -

на всякий спрошу, а в это время сами консумеры то отключены?

А оно не дало бы ничего сделать. Выкинуло бы ошибку.