前言:
本文
zookeeper所用版本为:zookeeper-3.4.14
kafka所用版本为:kafka_2.11-2.2.0
一:zookeeper安装部署
下载并拷贝zookeeper-3.4.14.tar.gz文件到linux的opt目录下
解压、进入到opt目录执行命令:tar -xvf zookeeper-3.4.14.tar.gz
解压完成后进入/opt/zookeeper-3.4.14/conf
-
拷贝文件、执行命令:cp zoo_sample.cfg zoo.cfg
-
编辑zoo.cfg文件
-
启动zookeeper
执行命令:/opt/zookeeper-3.4.14/bin/zkServer.sh start
二:kafka安装部署
下载并拷贝kafka_2.11-2.2.0.tgz文件到opt目录下
在opt目录下解压,执行命令:tar -xvf kafka_2.11-2.2.0.tgz
进入/opt/kafka_2.11-2.2.0/config目录
4.1 编辑server.properties文件
4.2编辑producer.properties文件
4.3编辑consumer.properties文件
- 前台启动kafka
执行命令:/opt/kafka_2.11-2.2.0/bin/kafka-server-start.sh /opt/kafka_2.11-2.2.0/config/server.properties
查看日志是否报错,如果没有报错可以ctrl+c然后进行后台启动
- 后台启动kafka
执行命令:/opt/kafka_2.11-2.2.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-2.2.0/config/server.properties
- 创建topic
/opt/kafka_2.11-2.2.0/bin/kafka-topics.sh --create --bootstrap-server ip:9092 --replication-factor 1 --partitions 1 --topic test