kafka 命令记录

Author Avatar
没饲养员的猩猩 09月 30,2021
  • 在其它设备中阅读本文章

查看全部消费者组
./kafka-consumer-groups.sh --bootstrap-server kafka集群地址 --list

查看groupid对应的消费情况
./kafka-consumer-groups.sh --bootstrap-server kafka集群地址 --group 消费者组ID --describe

重置offset 到最新
bin/kafka-consumer-groups.sh --bootstrap-server kafka集群地址 --group 消费者组ID --reset-offsets --topic icp_data_quality -to-latest --execute

取指定分区 制定topic的 最新多少条
./kafka-console-consumer.sh --bootstrap-server kafka集群地址 --topic 主题名 --partition 分区号 --max-messages 取出数据数量

手动设置offset
./kafka-consumer-groups.sh --bootstrap-server kafka集群地址 --group 消费者组ID --topic 主题名:分区号 --reset-offsets --to-offset offset位置数 –execute