kafka命令行脚本使用

时间:2022-11-09 09:36:05

zookeeper集群部署:http://www.cnblogs.com/ding2016/p/8280696.html

kafka集群部署:http://www.cnblogs.com/ding2016/p/8282907.html

 

测试环境

      kafka命令行脚本使用

 

测试流程:①主线:创建topoic,生产消息,消费消息;

      ②流程命令会连接不同的节点,可以顺带检测集群消息同步情况;

      kafka命令行脚本使用

测试步骤

1. 先创建一个Topic

   [root@server-1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.1.21:2181 --replication-factor 3 --partitions 2 --topic google 

  kafka命令行脚本使用

 

2. 查看一下建好的Topic

   [root@server-1 bin]# ./kafka-topics.sh --list --zookeeper 192.168.1.23:2181 

  kafka命令行脚本使用

 

3. 在建好的Topic下生产消息

   [root@server-1 bin]# ./kafka-console-producer.sh --broker-list 192.168.1.21:9092 --topic google 

  kafka命令行脚本使用

 

4. 消费指定Topic下的消息

   [root@server-1 bin]# ./kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --topic google --from-beginning 

  kafka命令行脚本使用

 

5. 删除指定Topic

  先list一下,然后删除:

   [root@server-1 bin]# ./kafka-topics.sh --delete --zookeeper 192.168.1.23:2181 --topic google 

  kafka命令行脚本使用

 

结束.