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

1. 创建topic命令

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

1. 创建product命令

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

1. 创建consunmer命令

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

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