计算机系统应用教程网站

网站首页 > 技术文章 正文

使用自带zookeeper安装单机kafka(适合刚接触kafka的同学)

btikc 2024-10-25 11:02:06 技术文章 15 ℃ 0 评论

本文介绍使用kafka自带的zookeeper安装 kafka环境,在实际使用中基本上不会这样去进行配置,对于之前没有接触过的同学通过这样的配置可以对zookeeper和kafka有一个初步的认识。
特别注意: 最新版的Kafka 2.8.0,移除了对Zookeeper的依赖,通过KRaft进行自己的集群管理。

前提条件

因为kafka是依赖于java环境运行的,所以需要在linux中安装java环境,请确保linux中安装了java环境

准备工作

下载kafka:kafka.apache.org/downloads

或者使用百度云:
链接:pan.baidu.com/s/11Mu5WVna…
提取码:pzpz

上传至服务器后解压:

tar -zxvf kafka_2.12-2.8.0.tgz 
复制代码

首先配置kafka自带的 zookeeper

第一步、 修改 config 下 zookeeper.properties
注意:其中 dataDir 是快照存放地址,clientPort是客户端连接 zookeeper 服务的端口
第二步、 修改config目录下的server.properties,修改log.dirs和zookeeper.connect。log.dirs是日志存放文件夹,zookeeper.connect是zookeeper连接地址(端口和clientPort保持一致)。
第三步、 至此,kafka单机版环境已搭建完毕。(如果对里面的参数没修改的话,可不修改,直接用默认的,但是需要记录一下默认配置的端口后续用的到,一般zookeeper默认端口为2181

启动zookeeper 和 kafka

注意:启动时所在的路径问题,需要kafka根目录下,因为要加载config中配置文件,在根目录下会比较方便些,还要注意端口是否被占用
启动 zookeeper(启动kafka自带的zookeeper(加上-daemon,可以让这个进程挂在后台进行,否则会发现是个阻塞进程,只能再开一个终端进行其他操作)
启动zookeeper命令:

./bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行:
./bin/kafka-server-start.sh -daemon config/server.properties
复制代码

启动 kafka 命令:

./bin/kafka-server-start.sh -daemon config/server.properties
复制代码

kafka常用命令

创建topic :
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看 topic 列表:
./bin/kafka-topics.sh -list -zookeeper localhost:2181
创建生产者:
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
创建消费者:
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
增加分区:
.bin/kafka-topics.sh --zookeeper localhost:2181/kafka --alter --topic topic-config --partitions 3


本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表