上传解压步骤省略
进入到kafka解压目录下的Config文件夹
修改配置文件:server.properties
vim server.properties
要点:
- broker.id=0 // 此设置在master主机不必更改,但此值是唯一值,slave1和slave2中要该为1和2
其次该值可以改为1 对应的slave1和slave2为2、3,亦可以是2、3、4,只要不一样就可以- delete.topic.enable=true该配置在2.X版本可能没有在Server.properties配置文件中没有写出,此配置为可以删除tipic,在1.X版本中为注释不生效状态,2.X版本中没有该项设置,可以添加。
- listeners=PLAINTEXT://:9092该配置为注释不生效状态,2.X版本请打开该选项,否则无法与其他两台从机中的kafka连接,该端口为监听端口。
- log.dirs=/usr/apps/tmp/kafka/logs该设置是已修改后的路径,默认应该在/tmp/kafka-logs文件夹中,该配置设置Kafka暂存文件或信息的位置,并不是log日志文件,因为Kafka生成的文件后缀名就是.log格式。
- zookeeper.connect=master:2181,slave1:2181,slave2:2181后面的:2181可以写,也可以不写,因为已经在/etc/hosts文件中配置了,Kafka会自主绑定端口
该文件夹下的zookeeper.properties中的dataDir=路径可以更改也可以不更改。
因为Kafka是以zookeeper为基础,所以要先启动zookeeper:
/usr/apps/kafka_2.11-2.0.0/bin/zookeeper-server-start.sh -deamon /usr/apps/kafka_2.11-2.0.0/config/zookeeper.properties
本文章中用到的为Kafka自带的zookeeper
说明:
- zookeeper启动文件:zookeeper-server-start.sh
- -daemon:守护进程模式,也就是后台启动,如果不后台启动,则会是一个阻塞线程,即打开后就停在那里,不能关闭窗口,若关闭窗口则关闭进程【服务】
- zookeeper.properties配置文件
合并解释:启动zookeeper进程,后台启动,使用该配置启动
启动Kafka:
/usr/apps/kafka_2.11-2.0.0/bin/kafka-server-start.sh -daemon /usr/apps/kafka_2.11-2.0.0/config/server.properties
具体说明请以上方的说明为例



