kafka之常用命令行操作

2018年5月3日11:36:37 发表评论 1,573 views

本文最后更新于 2018年6月5日 16:15 可能会因为没有更新而失效。如已失效或需要修正,请留言!

数据命令

1、启动kafka服务

zookeeper:主要设置clientPort(使用kafka自带的zookeeper)

start kafka server:

zookeeper.connect:zookeeper连接设置ip:port

broker.id:启动kafka的broker的id

2、创建topic

3、向topic中发送数据

4、开启一个消费端

check命令

1、查看kafka topic列表,使用--list参数
2、查看kafka特定topic的详情,使用--topic与--describe参数
3、查看consumer group列表,使用--list参数

查看consumer group列表有新、旧两种命令,分别查看新版(信息保存在broker中)consumer列表和老版(信息保存在zookeeper中)consumer列表,因而需要区分指定bootstrap--server和zookeeper参数:

4、查看特定consumer group 详情,使用--group与--describe参数

同样根据新/旧版本的consumer,分别指定bootstrap-server与zookeeper参数:

5、查看指定topic上每个partition的offset,是用于查看指定topic上相应分区的消息数,并不是consumer消费的偏移量

参考

apache 参考2

  • 我的微信
  • 这是我的微信扫一扫
  • weinxin
  • 我的微信公众号
  • 我的微信公众号扫一扫
  • weinxin

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: