kafka 入门安装手册

准备：

• kafka

kafka_2.12-1.1.1.tgz

• zookeeper

zookeeper-3.4.13.tar.gz

• jdk8

jdk-8u60-linux-x64.gz

安装：

• 配置jdk8

略

• 启动zookeeper

将zookeeper-3.4.13.tar.gz复制到/opt/app

解压tar -xvf zookeeper-3.4.13.tar.gz

将conf目录下文件改名
mv zoo_sample.cfg ./zoo.cfg

启动
./zkServer.sh start

验证
./zkCli.sh -server localhost:2181

• 启动kafka

vim config/server.properties

#集群状态不能重复
broker.id=0 

#kafka的地址增加目录
zookeeper.connect=localhost:2181/kafka

启动
bin/kafka-server-start.sh config/server.properties
后台启动
nohup bin/kafka-server-start.sh config/server.properties 2>&1 &

脚本：

• 创建topic

./kafka-topics.sh --create --topic 主题名称 --partitions 主题占用的分区数 --replication-factor 主题的备份数 --zookeeper zookeeper地址

例如：
./kafka-topics.sh --create --topic topic1 --partitions 3 --replication-factor 1 --zookeeper localhost:2181/kafka

提示创建成功
[root@limiao7 bin]# ./kafka-topics.sh --create --topic topic1 --partitions 3 --replication-factor 1 --zookeeper localhost:2181/kafka
Created topic "topicA".

• 查看topic

./kafka-topics.sh --list --zookeeper zookeeper地址

例如：
./kafka-topics.sh --list --zookeeper localhost:2181/kafka

结果：
[root@limiao7 bin]# ./kafka-topics.sh --list --zookeeper localhost:2181/kafka
topic1

• 修改topic

./kafka-topics.sh --alter --topic 主题名称 --config 配置项=配置值 --zookeeper zookeeper地址

例如：
./kafka-topics.sh --alter --topic topic1 --config 配置项=配置值 --zookeeper localhost:2181/kafka

• 删除topic

./kafka-topics.sh --delete --topic 主题名称 --zookeeper zookeeper地址

例如：
./kafka-topics.sh --delete --topic topic1 --zookeeper localhost:2181/kafka