常用命令

  • 查看当前服务器中的所有topic
$ sh bin/kafka-topics.sh --list --zookeeper zk01:2181

Note: 只写一个zk是因为每一个zk上的信息是一致的，所以可以写任意一个，但是如果 其中一台挂掉的话就会影响数据的获取，所以也可以把zk都写上。

  • 创建topic
$ sh bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
  • 删除topic
$ sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test

Note: 需要server.properties中设置delete.topic.enable=true,否则只是标记删除或者直接重启。

  • 通过shell命令发送消息
$ sh bin/kafka-console-producer.sh --broker-list kafka01:9092 --topic itheima

Notef: 同zk一样，Kafka中每个broker上都有一致的元信息(比如说：brokerList,partition信息等)，所以可以写任意一个，也可以都写上。

  • 通过shell消费消息
$ sh bin/kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test1
  • 查看group消费位置
$ sh bin/kafka-consumer-groups.sh --bootstrap-server base1:9092  --group opentsdb --describe
  • 查看某个Topic的详情
$ sh bin/kafka-topics.sh --topic test --describe --zookeeper zk01:2181
  • 修改topic分区
kafka-topics.sh --zookeeper base1:2181 --alter --partitions 13 --topic ce
  • 查看topic有多少数据
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic ce  --time -1 --broker-list base1:9092
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容