測試集群的部署情況需要使用的以下幾個命令

創建topic命令

kafka-topics.sh --create --zookeeper xx.xx.xx.xx:2181 --replication-factor x --partitions x --topic name

創建product命令

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

創建consunmer命令

./bin/kafka-console-consumer.sh --zookeeper xx.xx.xx.106:2181 --topic topic1 --from-beginning

查看topic分布情況命令

/kafka-topics.sh --describe --topic topic1 --zookeeper xx.xx.xx.106:2181

• 創建一個名為topic1 的topic 其分為三個partition 每個partition的replica為2 也就是每個分區有兩個備份:
  ./bin/kafka-topics.sh --create --zookeeper xx.xx.xx.106:2181 --replication-factor 2 --partitions 3 --topic topic1
• 查看這個topic的分布情況:
  bin/kafka-topics.sh --describe --topic topic1 --zookeeper xx.xx.xx.106:2181

如下圖:

• 然后在106啟動一個product發送消息
  ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic1
• 分別在107 和108 啟動consumer來消費
  ./bin/kafka-console-consumer.sh --zookeeper xx.xx.xx.107:2181 --topic topic1 --from-beginning

./bin/kafka-console-consumer.sh --zookeeper xx.xx.xx.108:2181 --topic topic1 --from-beginning

• 上面的啟動命令是老的啟動命令,最新的啟動命令支持加入對應的配置文件啟動,比如說:
  ./bin/kafka-console-consumer.sh --zookeeper xx.xx.xx.108:2181 --topic topic1 --from-beginning --consumer-property conf/consumer-properters
• 到此集群搭建和測試都已經完成,接下來需需要進行的是了解配置文件和進行新能調優

總結

以上是生活随笔為你收集整理的测试集群的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。