【Kafka】安装和配置
单机
安装和配置
- 下载并解压缩二进制版本
cd /opt/
wget https://archive.apache.org/dist/kafka/2.5.0/kafka_2.13-2.5.0.tgz
tar -xzvf kafka_2.13-2.5.0.tgz
- 后台启动自带Zookeeper
cd /opt/kafka_2.13-2.5.0
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >> zookeeper.nohup &
kafka需要依赖ZK,安装包中已经自带了一个ZK,也可以改成指定已运行的ZK。
如果改成指定的ZK需要修改修改 kafka 安装目录下的 config/server.properties 文件中的 zookeeper.connect 。
- 检查Zookeeper是否启动成功
ps -ef|grep zookeeper
- 修改Kafka配置文件
cd /opt/kafka_2.13-2.5.0
vim config/server.properties
broker.id=1
listeners=PLAINTEXT://192.168.247.132:9092
# 发送到不存在topic自动创建
auto.create.topics.enable=true
# 允许永久删除topic
delete.topic.enable=true
- 后台启动Kafka
cd /opt/kafka_2.13-2.5.0
nohup ./bin/kafka-server-start.sh ./config/server.properties >> kafka.nohup &
- 检查Kafka是否启动成功
ps -ef|grep kafka
- 停止Kafka
cd /opt/kafka_2.13-2.5.0
./bin/kafka-server-stop.sh ./config/server.properties
评论区