关注△mikechen△，十余年BAT架构经验倾囊相授！

Kafka是大型架构的必备中间件，下面我重点详解Kafka常用命令@mikechen

文章来源：mikechen.cc

1.启动kafka服务

命令：

bin/kafka-server-start.sh -daemon config/server.properties

2.停止kafka服务

命令：

./kafka-server-stop.sh

3.创建Topic

命令：

bin/kafka-topics.sh --create --topic test0--zookeeper 127.0.0.1:2181--config max.message.bytes=12800000--config flush.messages=1--partitions 5--replication-factor 1

参数说明：

–topic：后面的test0是topic的名称；

–zookeeper：应该和server.properties文件中的zookeeper.connect一样；

–config：指定当前topic上有效的参数值；

–partitions：指定topic的分区数量；

–replication-factor：指定每个分区的副本个数，默认1个；

4.查看所有的Topic列表

命令：

bin/kafka-topics.sh --list --zookeeper localhost:9092

5.查看所有的Topic的详细信息

命令：

bin/kafka-topics.sh --describe --zookeeper cdh-worker-1:2181/kafka

如果要查看单个 topic 信息：可在上述命令后面添加 –topic <topicName>。

6.查看Topic的分区和副本情况

命令：

bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181--topic test0

运行结果：

Topic:test0   PartitionCount:16ReplicationFactor:3Configs:Topic: test0  Partition:0Leader:0Replicas:0,2,1Isr:1,0,2 Topic: test0  Partition:1Leader:1Replicas:1,2,0Isr:1,0,2 Topic: test0  Partition:2Leader:2Replicas:2,0,1Isr:1,0,2 Topic: test0  Partition:3Leader:1Replicas:1,2,0Isr:1,0,2 Topic: test0  Partition:4Leader:2Replicas:2,0,1Isr:1,0,2 Topic: test0  Partition:5Leader:0Replicas:0,1,2Isr:1,0,2

7.删除一个Topic

命令：

bin/kafka-topics.sh --delete--zookeeper 127.0.0.1:2181--topic test0

8.Kafka发送消息

命令：

./kafka-console-producer.sh --broker-list localhost:9092 --topic test

9.Kafka接收消息

命令：加了–from-beginning 重头消费所有的消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092--topic test --from-beginning

命令：不加–from-beginning 从最新的一条消息开始消费

./kafka-console-consumer.sh --bootstrap-server localhost:9092--topic test

以上

本篇已收于mikechen原创超30万字《阿里架构师进阶专题合集》里面。