Сброс offset consumer group kafka
Сбросить consumer group на начало топика
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group <group> --topic <topic> --reset-offsets --to-earliest --execute
more kafka
all 20 commands →
Изменить количество партиций
kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic <name> --partitions 6
Offsets топика
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka:9092 --topic <name>
Создать топик
kafka-topics.sh --bootstrap-server kafka:9092 --create --topic my-topic --partitions 6 --replication-factor 3
Отставание consumer group
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group my-group
Сбросить offset consumer group
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute