Сброс текущей позиции для consumerGroup по topic#

Используется в случае, если необходимо прочитать предыдущие сообщения.

С помощью ansible#

Сбрасывает текущую позицию для consumerGroup по topic на последнюю запись. На сервере, с которого производилась установка, выполнить команду:

bin/kafka-consumer-groups.sh --bootstrap-server `hostname -f`:<порт> --group <наименование группы> --topic <наименование topic> --reset-offsets --to-latest --command-config ~/ssl_adm.properties

Варианты использования:

• для операции по всем topics к которым подключалась данная consumerGroup: --all-topics

• для операции по определенному topic: --topic <наименование topic>

• для операции по определенной партиции topic: --topic <наименование topic>:<partition>

Варианты перемещения текущей позиции:

• на запись в указанный момент времени: --to-datetime <YYYY-MM-DDTHH:mm:SS.sss>

• сдвиг на указанный промежуток времени от текущего: --by-period <PnDTnHnMnS>

• на самую раннюю из доступных записей: --to-earliest

• на последнюю запись: --to-latest

• сдвиг на указанное число позиций: --shift-by