1. 解压安装文件
链接:https://pan.baidu.com/s/1qzwYJeiHmb__do3lkkrLnA
提取码:1r8a
2. 进入 config 中修改 server.properties
3. 修改
host.name=hadoop1
port=9092
zookeeper.connect=hadoop1:2181
4. 启动 kafka, 首先需要先启动 zookeeper 然后执行如下命令启动 kafka
bin/kafka-server-start.sh -daemon ./config/server.properties
5. jps 查看
6. 验证 kafka
1》新建 topic 名字为:recommender1
bin/kafka-topics.sh --create --zookeeper hadoop1:2181 --replication-factor 1 --partitions 1 --topic recommender1
2》新开窗口,启动一个 console 生产者:
bin/kafka-console-producer.sh --broker-list hadoop1:9092 --topic recommender1
3》新开窗口,启动一个 console 消费者:
bin/kafka-console-consumer.sh --bootstrap-server hadoop1:9092 --topic recommender1
4》再 2》 中输入字符串, 3》窗口中就可以收到对应的字符串了