Читать топик с начала kafka
Прочитать все сообщения топика начиная с offset 0
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic <name> --from-beginning
more kafka
all 20 commands →
Отправить сообщения
kafka-console-producer.sh --bootstrap-server kafka:9092 --topic <name>
Список consumer groups
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --list
Lag consumer group
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group <group>
Сброс offset consumer group
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group <group> --topic <topic> --reset-offsets --to-earliest --execute
Изменить количество партиций
kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic <name> --partitions 6