如何部署集群测试环境? - 行业资讯 - 肥雀云

1、

/usr/local/kafka_2.9.2-0.8.2.2/bin/kafka-topics.sh--zookeeper devhadoop237:2181,devhadoop238:2181,devhadoop239:2181/kafka--create  --topic mytest --replication-factor 1 --partitions 3

/usr/local/kafka_2.9.2-0.8.2.2/bin/kafka-topics.sh——zookeeper  devhadoop237:2181 devhadoop238:2181 devhadoop239:2181/kafka ——列表

/usr/地方/kafka_2.9.2-0.8.2.2/bin/kafka-console-producer.sh——broker-list devhadoop237:9092 devhadoop238:9092 devhadoop239:9092 ——topicmytest

/usr/地方/kafka_2.9.2-0.8.2.2/bin/kafka-console-consumer.sh——zookeeper devhadoop237:2181、devhadoop238:2181 devhadoop239:2181/kafka ——topicmytest 从头