查看全部Topic:bin/kafka-topics.sh --list --zookeeper 10.160.7.205:2181,10.160.7.206:2181,10.160.7.207:2181d删除Topic:bin/kafka-topics.sh --topic testspark --delete --zookeeper 10.160.7.205:2181,10.160.7.206:2181,10.160.7.207:2181查看Topic明细:bin/kafka-topics.sh --topic testes --describe --zookeeper 10.160.7.205:2181,10.160.7.206:2181,10.160.7.207:2181Productor:bin/kafka-console-producer.sh --broker-list 10.160.7.203:9092,10.160.7.204:9092,10.160.7.205:9092,10.160.7.206:9092,10.160.7.207:9092 --topic testspark Consumer:bin/kafka-console-consumer.sh --zookeeper 10.160.7.203:2181,10.160.7.204:2181,10.160.7.205:2181,10.160.7.206:2181,10.160.7.207:2181 --topic testspark --from-beginning5个分区,并且复制因子为3日志预警:PublicVariable.STR_0x03bin/kafka-topics.sh --zookeeper 10.160.7.205:2181,10.160.7.206:2181,10.160.7.207:2181 --topic testspark --replication-factor 1 --partitions 5 --createnohup sh /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &WasException10.160.100.61:2
topic/te/1,10.160.7.206:218/bin/stspark/0.160.7.205:218/1,10.160.7.207:2181/zookeeper/kafka-topics.sh/10.160.100.61:2/
topic/te/1,10.160.7.206:218/bin/stspark/0.160.7.205:218/1,10.160.7.207:2181/zookeeper/kafka-topics.sh/10.160.100.61:2/
-->