Kafka手册

1.安装

tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz //解压zookeeper安装包

tar –zxvf kafka_2.12-2.6.0.tgz //解压kafka安装包

这里需要修改配置文件，为了后续方便，可以将zookeeper解压的配置文件拷贝到kafka的config文件夹中，具体修改配置项有zookeeper数据存放路径，日志路径，以及具体ip；

Zookeeper配置文件zookeeper.properties修改如下：

Kafka的配置文件，server.properties修改如下：

由于zookeeper涉及到apache，需要java环境，运行环境还需要安装jdk，直接解压到指定目录：/usr/java/，接着需要设置环境变量：

       export LD_LIBRARY_PATH=/soft/lib36:$LD_LIBRARY_PATH

       export JAVA_HOME=/usr/java/jdk1.8.0_65

       export JRE_HOME=${JAVA_HOME}/jre

       export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib

       export PATH=.:$JAVA_HOME/bin:/soft/lib36:/iHyperDB/library:$PATH:$KE_HOME/bin

1. 集群

当涉及到集群，安装步骤都一致，额外需要的是新建文件myid，其中写上brokeid+1的对应值即可，这里的myid就相当于一个标识，让集群中的kafka与zookeeper互相认识。

1. 启停

cd /opt/kafka/kafka_2.12-2.6.0  //进入kafka安装目录

bin/zookeeper-server-start.sh –daemon config/zookeeper.properties  //启动zookeeeper

bin/zookeeper-server-stop.sh -daemon config/zookeeper.properties  //停止zookeeper

bin/kafka-server-start.sh -daemon config/server.properties       //启动kafka

bin/kafka-server-stop.sh -daemon config/server.properties       //停止kafka

1. Topic创建

Kafka的主题创建有两种方式，命令行与代码创建。命令行创建需要进入bin目录：

./kafka-topics.sh –create –zookeeper ip:2181 – replication-factor 1 –partions 1 –topic test

查看主题:

./kafka-topics.sh –list –zookeeper ip:2181

如果是单个kafka，代码创建即可，涉及到集群，建议还是通过命令行创建Topic更为稳妥。