Kafka命令

1、开启zookeeper、Kafka、kafka-manager服务（nohup …… &表示后台执行）

nohup bin/zkServer.sh start conf/zoo.cfg &

nohup bin/kafka-server-start.sh config/server.properties &

nohup ./kafka-manager-Dconfig.file=../conf/application.conf &

2. 创建topic（任意IP或localhost均可）

bin/kafka-topics.sh --create --zookeeper 192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181 --replication-factor 2 --partitions 3 --topic test

bin/kafka-topics.sh --create --zookeeper 192.168.43.209:2181 --replication-factor 2 --partitions 1 --topic test2

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test3

3. 查看topic列表（任意IP或localhost均可）

bin/kafka-topics.sh --list --zookeeper 192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181

bin/kafka-topics.sh --list --zookeeper 192.168.43.209:2181

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

4. 查看topic详情（任意IP或localhost均可）

bin/kafka-topics.sh --describe --zookeeper 192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181 --topic test1

bin/kafka-topics.sh --describe --zookeeper 192.168.43.209:2181 --topic test1

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test1

5. 发布者发布消息（任意IP均可，localhost不行）

bin/kafka-console-producer.sh --broker-list 192.168.43.209:9092,192.168.43.210:9092,192.168.43.211:9092 --topic test1

bin/kafka-console-producer.sh --broker-list 192.168.209:9092 --topic test1

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1（不行）

6. 消费者消费消息（任意IP或localhost均可）

bin/kafka-console-consumer.sh --zookeeper 192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181 --topic test1 --from-beginning

bin/kafka-console-consumer.sh --zookeeper 192.168.43.209:2181 --topic test1 --from-beginning

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1 --from-beginning

7. 删除topic（delete.topic.enable=true）

bin/kafka-topics.sh --delete --zookeeper 192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181 --topic test

8. Kafka集群管理（网页）

firefox命令打开浏览器，输入如下网址：

192.168.43.209:9000

加权限控制之后：

9. 添加生产者权限

bin/kafka-acls.sh --add --authorizer-properties zookeeper.connect=192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181 --allow-principal User:sce --producer --topic=test

10. 添加消费者权限

bin/kafka-acls.sh --add --authorizer-properties zookeeper.connect=192.168.43.209:2181,192.168.43.210:2181,192.168.43.211:2181  --allow-principal User:sce --consumer --group sce --topic=test15

11. 查看topic权限

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=192.168.43.209:2181 --list --topic test2

12. 删除权限

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=192.168.43.209:2181 --operation Write --operation Read --operation Describe --allow-principal User:admin --allow-host * --remove --topic test2

13. 发布消息

bin/kafka-console-producer.sh --broker-list 192.168.43.209:9092,192.168.43.210:9092,192.168.43.211:9092 --producer-property security.protocol=SASL_PLAINTEXT --producer-property sasl.mechanism=PLAIN --topic test15

14. 订阅消息

bin/kafka-console-consumer.sh --bootstrap-server 192.168.43.209:9092,192.168.43.210:9092,192.168.43.211:9092 --consumer-property security.protocol=SASL_PLAINTEXT --consumer-property sasl.mechanism=PLAIN --topic test3