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
修改內容如
4.配置環境變數#broker的全域性唯一編號,不能重複
broker.id=0
#刪除topic功能使能
delete.topic.enable=true
#配置連線zookeeper集群位址
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181
vim /etc/profile
配置內容如下
5.分發到hadoop02、hadoop03#kafka_home
export kafka_home=/usr/local/kafka_2.11-0.11.0.0
export path=
$path
:$kafka_home/bin
6.修改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/
vim server.properties
修改內容如下
hadoop02
broker.id=1
hadoop03
broker.id=2
安裝kafka 集群
wget org kafka 1.0 0 kafka 2.11 1.0 0.tgz tar zxvf kafka 2.11 1.0 0.tgz vi kafka 2.11 1.0 0 config server.properties主要修改的有如下 log.dirs home data kafka ...
kafka安裝使用
先來說下kafka是個什麼東西,它是乙個訊息中介軟體框架,只負責發布 訂閱 幫忙存東西的 接著給大家看一張大致的kafka流程圖 首先打個比方,kafka好比就是 電視台,而 電視台下面有很多節目,生產者就是製作節目的團隊,而消費者就是我們 這個節目的人,一開始 電視台建立乙個節目,假設就叫cctv...
kafka集群安裝
請參考上一章zookeepe集群安裝 wget org kafka 0.9 0.1 kafka 2.11 0.9 0.1 tgz tar xzf kafka 2.11 0.9 0.0 tgzbroker.id 0 整個集群內唯一id號,整數,一般從0開始 listeners plaintext 1....