前置条件
/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服务【所有服务器都执行】
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
3.2 启动kafka服务【所有服务器都执行】
nohup bin/kafka-server-start.sh config/server.properties &
3.3 创建主题：
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
