前置條件
/opt/kafka
1.zookeeper 配置
/opt/kafka/config/zookeeper.properties
添加：
initLimit=5
syncLimit=2
server.1=master1:2888:3888
server.2=slave1:2888:3888
2.kafka Server 配置
/opt/kafka/config/server.properties
第一臺：【broker.id哲泊，hostname不能重復】
broker.id=1
port=9092
host.name=master1
zookeeper.connect=master1:2181,slave1:2181
__________________________________________
第二臺
broker.id=2
port=9092
host.name=slave1
zookeeper.connect=master1:2181,slave1:2181
3.測試
3.1 啟動zookeeper服務【所有服務器都執(zhí)行】
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
3.2 啟動kafka服務【所有服務器都執(zhí)行】
nohup bin/kafka-server-start.sh config/server.properties &
3.3 創(chuàng)建主題：
bin/kafka-topics.sh --create --replication-factor 1 --partition 2--topic user-behavior-topic --zookeeper master1:2181,slave1:2181
3.4 生產消息：
bin/kafka-console-producer.sh --broker-list ?master1:9092 --topic user-behavior-topic
3.5 消費消息：
bin/kafka-console-consumer.sh --zookeeper master1:2181 --topic user-behavior-topic --from-beginning
