我们这里是在Debian12上进行的操作;直接从kafka官网https://kafka.apache.org/downloads上下载安装即可
一、单节点kafka部署
1.1 配置单节点zookeeper
直接使用kafka安装包中自带的zookeeper即可。相关配置文件在config/zookeeper.properties中,做如下修改即可:
# 存放zookeeper的数据文件
dataDir=/home/debian/kafka/zk/data
# 存放zookeeper的日志文件
dataLogDir=/home/debian/kafka/zk/logs
注:dataDir和dataLogDir目录需要提前创建好,其他配置项保持默认即可。
mkdir -p /home/debian/kafka/zk/data
mkdir -p /home/debian/kafka/zk/logs
1.2 配置单节点kafka
配置文件在config/server.properties中,做如下修改即可:
# broker的id
broker.id=1
# kafka要监听的地址
listeners=PLAINTEXT://192.168.0.110:9092
# kafka日志存放的目录
log.dirs=/home/debian/kafka/logs
# zookeeper地址,若是集群,则多个地址用逗号(半角)隔开即可
zookeeper.connect=127.0.0.1:2181
1.3 启动和停止
注意需要先安装jdk才行;同时刚开始时启动参数最好不加
-daemon
,该参数表示后台执行,否则会卡住。(方便查看是否启动成功)
启动:
# 进入kafka的bin目录下执行如下命令
./zookeeper-server-start.sh -daemon ../config/zookeeper.properties #启动zookeeper
./kafka-server-start.sh -daemon ../config/server.properties #启动kafka
停止:
./zookeeper-server-stop.sh #停止zookeeper
./kafka-server-stop.sh #停止kafka,关不就用kill -9直接杀掉
查看是否有zookeeper和kafka进程:
jps