miller
发布于

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

kafka 参数:
https://www.cnblogs.com/dayu123/p/16486319.html

浏览 (13)
点赞
收藏
评论