欢迎访问IT教程网

kafka命令操作

Linux admin 456℃ 0评论

1)查看当前服务器中的所有topic

$ bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

2)创建topic

$ bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 \

--create --replication-factor 3 --partitions 1 --topic first

选项说明:

--topic 定义topic

--replication-factor  定义副本数,不能超过节点数

--partitions  定义分区数

3)删除topic

$ bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 \

--delete --topic first

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

4)发送消息连接broker

$ bin/kafka-console-producer.sh \

--broker-list 127.0.0.1:9092 --topic first

>hello world  

>haha

5)消费消息连接zk 控制台默认只能获取到最新的 之前的接收不到

$ bin/kafka-console-consumer.sh \

--bootstrap-server  127.0.0.1:9092  --from-beginning --topic first

--from-beginning会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

6)查看某个Topic的详情

$ bin/kafka-topics.sh --zookeeper 127.0.0.1 :2181 \

--describe --topic first

 

 

 

本文固定链接:IT教程网 » kafka命令操作
本站内容除特别标注外均为原创,欢迎转载,但请保留出处!

喜欢 (0)
发表我的评论
取消评论
表情

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址