Сбросить offset consumer group kafka
Сбросить offsets на начало топика
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute
more kafka
all 20 commands →
Отправить сообщения из stdin
kafka-console-producer.sh --bootstrap-server kafka:9092 --topic my-topic --property 'key.separator=:' --property 'parse.key=true'
Читать с начала топика
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic my-topic --from-beginning --max-messages 10
Изменить количество партиций
kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12
Конфигурация топика
kafka-configs.sh --bootstrap-server kafka:9092 --describe --entity-type topics --entity-name my-topic
Задать retention топика
kafka-configs.sh --bootstrap-server kafka:9092 --alter --entity-type topics --entity-name my-topic --add-config retention.ms=604800000