zookeeper集群部署:http://www.cnblogs.com/ding2016/p/8280696.html
kafka集群部署:http://www.cnblogs.com/ding2016/p/8282907.html
測試環境:
測試流程:①主線:創建topoic,生產消息,消費消息;
②流程命令會連接不同的節點,可以順帶檢測集群消息同步情況;
測試步驟:
1. 先創建一個Topic
[root@server-1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.1.21:2181 --replication-factor 3 --partitions 2 --topic google
2. 查看一下建好的Topic
[root@server-1 bin]# ./kafka-topics.sh --list --zookeeper 192.168.1.23:2181
3. 在建好的Topic下生產消息
[root@server-1 bin]# ./kafka-console-producer.sh --broker-list 192.168.1.21:9092 --topic google
4. 消費指定Topic下的消息
[root@server-1 bin]# ./kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --topic google --from-beginning
5. 刪除指定Topic
先list一下,然后刪除:
[root@server-1 bin]# ./kafka-topics.sh --delete --zookeeper 192.168.1.23:2181 --topic google
結束.