消息中间件--04. Kafka常用的命令
启动zookeeper
$ bin/zkServer.sh start conf/zoo.cfg &
$ bin/zkCli.sh 启动Kafka
我们启动两个实例：
$ bin/kafka-server-start.sh -daemon config/server.properties
$ bin/kafka-server-start.sh -daemon config/server-1.properties 启动后，使用jps进程查看对应的kafka进程：
Kafka常用的命令
创建主题
现在我们来创建一个名字为testTopic和testTopic1 的Topic，这个topic有两个partition，并且备份因子也设置为2：
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic testTopic
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic testTopic1查看Kafka的实例
$ bin/zkCli.sh
$ ls / #查看zk的根目录kafka相关节点
$ ls /brokers/ids #查看kafka节点
Kafka常用的命令
查看所有的topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
Kafka常用的命令
除了我们通过手工的方式创建Topic，我们可以配置broker，当producer发布一个消息某个指定的Topic，但是这个Topic并不存在时，就自动创建。
查看partition的作用
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic testTopic
Kafka常用的命令
发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic消费消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --consumer-property group.id=testGroup --consumer-property client.id=consumer-1 --topic testTopic 删除Topic
kafka-topics.sh --zookeeper localhost:2181 --delete --topic <topic_name>(本文完)
作者:付威 博客地址:http://blog.laofu.online 本文是付威的网络博客原创，自由转载-非商用-非衍生-保持署名,请遵循：创意共享3.0许可证 交流请加群113249828： 点击加群 或发我邮件 laofu_online@163.com
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2020-02-13 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录
腾讯云开发者
