kafka安装较为简单,不同操作系统下安装步骤基本相同,针对大多数用户来讲,在生产环境使用kafka一般选择linux服务器:

在Linux系统上安装kafka与在windows系统上安装操作基本相同,将安装包解压到相应目录,这里依然将kafka安装目录记为$KAFKA_HOME,修改$KAFKA_HOME/config/server.properties文件相关配置即可,这里安装kafka所用机器与安装zookeeper的机器相同,但在生产环境,一般将zookeeper集群与kafka机器分机架部署

(1)解压安装

tar zxvf kafka_2.12-2.1.0.tgz

(2)修改配置

修改$KAFKA_HOME/config/目录下的server.properties文件,为了便于后续集群环境搭建的配置,需要保证同一个集群下broker.id要唯一,因此这里弓手配置broker.id,直接保持与zookeeper的myid一致,同时配置日志存储路径,server.properties修改的配置如下:

broker.id = 1

其他配置保持不变,由于这台机器本地已安装了zookeeper,因此暂不对zookeeper.connect配置进行修改,其他配置文件也暂不进行修改

(3)验证

启动kafka,要保证zookeeper已正常启动,进入kafka安装路径$KAFKA_HOME/bin目录下,执行启动kafkaServer命令

./kafka-server-start.sh -daemon ../config/server.properties

执行jps命令查看java进程,此时进程信息至少包括一下几项:

[root@inter bin]# jps

23040 Jps

22209 QuorumPeerMain

22961 Kafka

可以看到zookeeper进程和kafka进程名,同时进入logs目录下,查看server.log会看到kafkaServer启动日志,在启动日志中会记录kafkaServer启动时加载的配置信息

[root@inter kafka-logs]# cat meta.properties

#

#Mon Feb 11 16:03:14 CST 2019

version=0

broker.id=1

通过zookeeper客户端登录zookeeper查看目录结构,执行以下命令:

[root@inter bin]# ./zkCli.sh -server kafka-1:2181

Connecting to kafka-1:2181

查看zookeeper目录结构

在kafka启动之前zookeeper中只有一个zookeeper目录节点,kafka启动后目录节点如下:

WatchedEvent state:SyncConnected type:None path:null

ls /

[cluster, controller_epoch, controller, brokers, zookeeper, admin, isr_change_notification, consumers, log_dir_event_notification, latest_producer_id_block, config]

[zk: kafka-1:2181(CONNECTED) 1]

执行以下命令,查看当前已启动的kafka代理节点:

[zk: kafka-1:2181(CONNECTED) 2] ls /brokers/ids

[1]

输出信息显示当前只有一个kafka代理节点,当前代理的brokerId为1