安装
kafka 的安装:
kafka 的安装必须要先安装 zk,必须要保证时钟同步
第一步:下载上传解压压缩包
cd /export/softwares tar -zxvf kafka_2.11-1.0.0.tgz -C ../servers/
|
第二步:修改配置文件
第一台修改配置文件
cd /export/servers/kafka_2.11-1.0.0/config vim server.properties
|
server.propertiesbroker.id=0 log.dirs=/export/servers/kafka_2.11-1.0.0/logs zookeeper.connect=node01:2181,node02:2181,node03:2181 delete.topic.enable=true host.name=node01 scp -r kafka_2.11-1.0.0/ node02:$PWD
|
第二台修改配置文件
cd /export/servers/kafka_2.11-1.0.0/config vim server.properties
|
server.propertiesbroker.id=1 log.dirs=/export/servers/kafka_2.11-1.0.0/logs zookeeper.connect=node01:2181,node02:2181,node03:2181 delete.topic.enable=true host.name=node02 scp -r kafka_2.11-1.0.0/ node03:$PWD
|
第三台修改配置文件
cd /export/servers/kafka_2.11-1.0.0/config vim server.properties
|
server.propertiesbroker.id=2 log.dirs=/export/servers/kafka_2.11-1.0.0/logs zookeeper.connect=node01:2181,node02:2181,node03:2181 delete.topic.enable=true host.name=node03
|
第三步:三台机器启动 kafka 集群
前台启动
bin/kafka-server-start.sh config/server.properties
|
进程后台启动
nohup bin/kafka-server-start.sh config/server.properties &
|