Linux系列——Kafka的安装与测试

行是知之始,知是行之成。这篇文章主要讲述Linux系列——Kafka的安装与测试相关的知识，希望能为你提供帮助。
前言： linux系统版本：CentOS6.7
JDK版本：1.8（JDK安装过程参考：点击打开链接）
ZooKeeper版本：3.4.6（ZooKeeper安装过程参考：点击打开链接）
Kafka版本：1.1.0
安装 step1 下载并解压 wget http://mirrors.shu.edu.cn/apache/kafka/1.1.0/kafka_2.11-1.1.0.tgz
tar –zxvf kafka_2.11-1.1.0.tgz
mv kafka_2.11-1.1.0.tgz kafka （修改文件名）
step2 添加文件夹在kafka根目录下添加文件夹logs
mkdir logs

文章图片

step3 修改配置文件进入解压后的目录，修改server.properties文件：
vim/usr/local/kafka/config/server.properties
依次修改下面的内容：
broker.id=0#根据服务器情况修改值，可以为0,1,2...
port=9092#端口号
host.name=192.168.24.128#服务器ip
advertised.host.name=192.168.24.128#服务器ip
log.dirs=/usr/local/kafka/logs#logs文件路径
num.partitions=2#分区数量
zookeeper.connect=192.168.24.128:2181, 192.168.24.129:2181, 192.168.24.130:2181#zookeeper服务器url

文章图片

文章图片

step4 启动kafka 首先启动ZooKeeper：
zkServer.sh start
进入到kafka根目录下：
cd /usr/local/kafka
启动kafka：
bin/kafka-server-start.sh config/server.properties &
下面的是broker为1的启动结果：