安裝包下載

前置準備

jdk映象
kafka安裝包

解壓

tar -zxvf kafka_2.10-0.8.2.1.tgz -C /usr/local
mv kafka_2.10-0.8.2.1 kafka
cd /usr/local/kafka/config

修改配置檔案:

cp server.properties server.properties.bak
vim server.properties

修改如下內容:
刪除broker.id=0
刪除host.name=
增加delete.topic.enable=true
修改log.cleaner.enable=true
修改zookeeper.connect=zk1:2181,zk2:2181,zk3:2181

上面兩個引數由於每個容器不同，所以我們暫時刪除，在容器啟動時注入就可以啟動多個不同的容器了

修改/etc/hosts

增加zk和kafka對映

配置環境變數

vim /etc/bashrc

增加KAFKA_HOME並修改PATH 如果希望docker自啟動開啟kafka可以在裡面增加kafka開啟命令

然後就可以commit了。 執行新docker:

docker run -itd --name xxx -e BROKER_ID=0 -e MY_HOST_NAME=kafka1 \
--net 子網 --ip kafkaIp containerId \
sh -c 'cp /tmp/hosts
 
 /etc/hosts && echo -e "broker.id=$BROKER_ID\nhost.name=$MY_HOST_NAME" >> /usr/local/kafka/config/server.properties && /bin/bash'

修改-e引數即可啟動多個不同的kafka節點