Kafka安装和常用操作命令

Kafka作为分布式流式数据处理中间件,为了掌握Kafka,学会常用的Kafka命令是学好Kafka的基础。Kafka使用zookeeper作为注册中心,因此在使用Kafka之前,首先要准备好zookeeper,因为只是对常用命令介绍,本文档只是使用Kafka单机和zookeeper单机配置,操作系统使用的Mac OS,zookeeper使用的版本为zookeeper-3.4.12,Kafka使用的版本为2.0.11;

安装配置启动zookeeper
首先从官网(http://zookeeper.apache.org)下载zookeeper压缩包,然后解压;然后对zookeeper进行简单配置:
启动Mac终端Shell,并进入到解压zookeeper的conf目录下,新建zoo.cfg文件,然后进行配置,对应的Linux命令如下:

cd  /Users/lichao/Documents/zookeeper-3.4.12/conf #进入到zookeeper配置文件目录下
vim zoo.cfg #新建并打开配置文件

Kafka安装和常用操作命令
然后在zoo.cfg配置如下几项:
Kafka安装和常用操作命令
基本配置完成之后,进入到zookeeper-3.4.12下面的bin目录下,使用zkServer.sh启动脚本启动zookeeper;当出现STARTED是则表示启动成功,具体如下图:
Kafka安装和常用操作命令
到目前为止,zookeeper已经启动完成;接下来就是启动Kafka。
安装配置启动Kafka
kafka安装的版本为kafka_2.11-2.0.0,所有的配置文件存放kafka根目录下面的config文件夹下:
/Users/lichao/Documents/kafka_2.11-2.0.0/config,对应的文件根据名称可以知道相应的配置;