Debian12上安装Kafka3


下面的教程是基于kafka3.9.0版本来进行的,下载的时候下载 kafka_2.13-3.9.0.tgz

一、单节点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,该参数表示后台执行,否则会卡住。(方便查看是否启动成功)

启动,进入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

特别提醒:扫码关注微信订阅号'起岸星辰',实时掌握IT业界技术资讯! 转载请保留原文中的链接!
  目录