实现步骤:
1.从官网下载安装包 http://kafka.apache.org/downloads
2.上传到01虚拟机,解压
3.进入安装目录下的config目录
4.对server.properties进行配置
配置示例:
broker.id=0
log.dirs=/home/software/kafka/kafka-logs
zookeeper.connect=hadoop01:2181,hadoop02:2181,hadoop03:2181
delete.topic.enable=true
advertised.host.name=192.168.234.21
advertised.port=9092
5.保存退出后,别忘了在安装目录下创建 kafka-logs目录
6.配置其他两台虚拟机,更改配置文件的broker.id编号(不重复即可)
7.先启动zookeeper集群
8.启动kafka集群
进入bin目录
执行:sh kafka-server-start.sh ../config/server.properties