Kafka常用命令

1. 创建topic
      # 注意：一般在系统设计的时候，先把topic规划好，业务含义相同的数据，放在一个topic中。
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --create   --topic topica --partitions 3 --replication-factor 2

## ---------------参数说明------------------ ##
--zookeeper 连接的zookeeper
--create 表示要创建一个topic
--topic 指定topic的名字(不同业务的数据，放在不同的topic中)
--partitions 指定分区数
--replication-factor 指定副本数

2. 查看所有topic
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --list

3. 查看某个topic详情
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --describe --topic topica

4. 删除topic
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --delete   --topic topica

5. 接收消息
[root@kafka1 kafka]# bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic topica

6. 发送消息
[root@kafka1 kafka]# bin/kafka-console-producer.sh --broker-list      kafka1:9092 --topic topica

7. 启动集群
bin/kafka-server-start.sh -daemon config/server.properties
 
8. 关闭集群
bin/kafka-server-stop.sh