准备安装包
kafka下载
ZooKeeper下载
配置zookeeper
- 解压文件
tar -xzf apache-zookeeper-3.9.3-bin.tar.gz
- 修改配置文件
cd apache-zookeeper-3.9.3-bin/conf
cp zoo_sample.cfg zoo.cfg
//创建文件夹
mkdir /data/zookeeper
vim zoo.cfg
//修改
dataDir=/data/zookeeper
- 启动
cd apache-zookeeper-3.9.3-bin/bin
./zkServer.sh start
配置kafka
- 解压文件
tar -xzf kafka_2.13-3.9.0.tgz
- 修改配置文件
cd kafka_2.13-3.9.0/config
cp server.properties server.properties.orig
//创建文件夹
mkdir /data/kafka-logs
vim server.properties
//修改配置
log.dirs=/data/kafka-logs
- 启动
cd kafka_2.13-3.9.0/bin
./kafka-server-start.sh -daemon ../config/server.properties
测试
./kafka-topics.sh --create --topic test --bootstrap-server localhost:9092
./kafka-producer-perf-test.sh --topic test --num-records 1000 --record-size 1 --throughput -1 --producer-props bootstrap.servers=localhost:9092
./kafka-consumer-perf-test.sh --topic test --bootstrap-server localhost:9092 --messages 1000
