kafka_2.11-0.11.0.0 安裝配置

1.上傳kafka_2.11-0.11.0.0.tgz
2.解壓

tar -zxvf kafka_2.11-0.11.0.0.tgz -C /usr/local/

3.修改server.properties

vim server.properties

修改內容如

#broker的全局唯一編號，不能重復
broker.id=0
#刪除topic功能使能
delete.topic.enable=true
#配置連接Zookeeper集群地址
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181

4.配置環境變量

vim /etc/profile

配置內容如下

#KAFKA_HOME
export KAFKA_HOME=/usr/local/kafka_2.11-0.11.0.0
export  PATH=$PATH:$KAFKA_HOME/bin

5.分發到hadoop02、hadoop03

scp -r /usr/local/kafka_2.11-0.11.0.0/ hadoop02:/usr/local/
scp -r /usr/local/kafka_2.11-0.11.0.0/ hadoop03:/usr/local/

6.修改hadoop02和hadoop03配置文件

vim server.properties

修改內容如下
hadoop02

broker.id=1

hadoop03

broker.id=2