测试集群的部署情况需要使用的以下几个命令
- 创建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 - 到此集群搭建和测试都已经完成,接下来需需要进行的是了解配置文件和进行新能调优
