1. 创建主题
在客户端就可以创建
指定主题名字topic1,指定partition 副本数为3(不能超过集群节点数),指定分区数目 4 ,指定zk节点
./kafka-topics.sh --create --topic topic1 --replication-factor 3 --partitions 4 --zookeeper 10.10.100.215:2181
Created topic "topic1".
创建了4个分区
2.查看主题
[root@elasticsearch-1 bin]# ./kafka-topics.sh --list --zookeeper 10.10.100.215 2181
topic1
3.启动消费者
消费者会一直组塞着
./kafka-console-consumer.sh --zookeeper 10.10.100.215:2181 --topic topic1
4.启动生产者
指定215、216、217 任何一个broker 都可以。注意端口是9092
./kafka-console-producer.sh --broker-list 10.10.100.216:9092 --topic topic1
输入数据即可,消费者可以监听到