kafka 操作
也可参考下边 3 个开源,
kafka-ui https://github.com/provectus/kafka-ui
https://github.com/dushixiang/kafka-map
https://github.com/xxd763795151/kafka-console-ui
问 AI:
查看所有 topic
./kafka-topics.sh --bootstrap-server kafka-cs:9092 --list
查看tccloud-otep 此消费组的消费情况
./kafka-consumer-groups.sh --bootstrap-server kafka-cs:9092 --group tccloud-otep --describe
手动重置 Offset:
./kafka-consumer-groups.sh --bootstrap-server kafka-cs:9092 --group tccloud-otep --reset-offsets --to-latest --execute
./kafka-consumer-groups.sh --bootstrap-server kafka-cs:9092 --group tccloud-otep --reset-offsets --to-earliest-xxx --all-topics --execute
手动设置 Offset 注意数字:
kafka-consumer-groups.sh --bootstrap-server kafka-cs:9092 --group tccloud-otep --reset-offsets --to-offset xxxooo --execute
kafka-consumer-groups.sh --bootstrap-server <broker-address> --group <group-id> --reset-offsets --to-offset <offset> --topic <topic-name> --execute
查看 Kafka 主题的保留策略:
./kafka-topics.sh --bootstrap-server kafka-cs:9092 --describe --topic OTEP_EVENT
调整 Kafka 的日志保留时间((7 天,单位毫秒)): XXX 未试过
kafka-configs.sh --bootstrap-server kafka-cs:9092 --entity-type topics --entity-name OTEP_EVENT --alter --add-config retention.ms=604800000