测试集群

测试集群的部署情况需要使用的以下几个命令

创建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
• 到此集群搭建和测试都已经完成,接下来需需要进行的是了解配置文件和进行新能调优

总结

以上是生活随笔为你收集整理的测试集群的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。