Kafka集群搭建
//启动zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
//启动集群中所有的kafka
bin/kafka-server-start.sh -daemon config/server.properties
//创建topic,设置副本和分区:
bin/kafka-topics.sh --create --zookeeper 192.168.1.5:2181 --replication-factor 4 --partitions 4 --topic test
Kafka集群搭建
//启动zookeeper:
bin/zookeeper-server-sta