前置條件

/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

第一臺(tái)：【broker.id，hostname不能重復(fù)】

broker.id=1

port=9092

host.name=master1

zookeeper.connect=master1:2181,slave1:2181

__________________________________________

第二臺(tái)

broker.id=2

port=9092

host.name=slave1

zookeeper.connect=master1:2181,slave1:2181

3.測(cè)試

3.1 啟動(dòng)zookeeper服務(wù)【所有服務(wù)器都執(zhí)行】

nohup bin/zookeeper-server-start.sh config/zookeeper.properties &

3.2 啟動(dòng)kafka服務(wù)【所有服務(wù)器都執(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 生產(chǎn)消息：

bin/kafka-console-producer.sh --broker-list ?master1:9092 --topic user-behavior-topic

3.5 消費(fèi)消息：

bin/kafka-console-consumer.sh --zookeeper master1:2181 --topic user-behavior-topic --from-beginning