kafka常见操作
kafka查看数据
·
查看
- 查看topic列表
./kafka-topics.sh --bootstrap-server 0.0.0.0:9092 --list
- 查看消费组列表
./kafka-consumer-groups.sh --bootstrap-server 0.0.0.0:9092 --list
- 查看消费组有无数据
./kafka-console-consumer.sh --bootstrap-server 0.0.0.0:9092 --topic tocpi名 --from-beginning
# 若没有任何返回或没有响应,则该topic中没有数据内容;否则就是有数据 --from-beginning
- 查看 lga偏移量
./kafka-consumer-groups.sh --bootstrap-server 0.0.0.0:9092 --group 消费组名 --describe
## --describe 从历史数据开始查看
- 消除lga堆积偏移量
./kafka-consumer-groups.sh --bootstrap-server 0.0.0.0:9092 --group 消费组名 --reset-offsets --all-topics --to-latest --execute
- 添加 partitions消费分区数
kafka-topics.sh --alter --partitions 3 --topic topic名 --bootstrap-server 0.0.0.0:9092
更多推荐
所有评论(0)