kafka構成

1467 ワード

server.properties構成
#          
broker.id=0

#        topic
delete.topic.enable=true

#       
log.dirs=/opt/module/kafka/data

#      7 
log.retension.hours=168

#zookeeper  
zookeeper.connect=hadoop1:2181,hadoop2:2181,hadoop3:2181

環境変数構成(オプション)/etc/profile
#KAFKA
export KAFKA_HOME=/opt/module/kafka
export PATH=$PATH:$KAFKA_HOME/bin

source /etc/profile

#  ,                

xsync kafka/

他のマシンserverを変更します.propertiesファイルのbroker.id
broker.id=1

クラスタの起動
// 1.   zk
zk.sh start

// kafka( )
bin/kafka-server-start.sh -daemon config/server.properties