Kafka0.10.0.0单节点-多代理集群

一、接着上篇单节点-单代理集群，继续开启两个新代理，架构如下图

cp server.properties server-1.properties
cp server.properties server-2.properties

分配配置如下
broker.id=1
port=9093
log.dir=/tmp/kafka-logs-1
 
broker.id=2
port=9094
log.dir=/tmp/kafka-logs-2

二、分别开启代理服务器

bin/kafka-server-start.sh config/server-1.properties

bin/kafka-server-start.sh config/server-2.properties

三、创建主题

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic replicated-kafkatopic

四、开启生产者和消费者

bin/kafka-console-producer.sh --broker-list localhost:9092,localhost:9093 --topic replicated-kafkatopic //生产者

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic replicated-kafkatopic //消费者

五、查看Leader

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic replicated-kafkatopic

用JAVA开发的话，所有的JAR包都在安装目录的libs下