网站首页 > 技术文章 正文
本文介绍使用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
猜你喜欢
- 2024-10-25 不用 zookeeper 照样部署kafka集群
- 2024-10-25 Kafka最全详解(图文全面总结) kafka基础知识
- 2024-10-25 深入了解Apache Kafka 深入了解对方的36个问题
- 2024-10-25 kafka和zookeeper在k8s集群踩的一些坑
- 2024-10-25 Kafka 2.8独立运行,不再需要ZooKeeper
- 2024-10-25 告别 ZooKeeper:Kafka 将提供自管理的元数据仲裁机制
- 2024-10-25 Kafka架构最全详解(图文全面总结)
- 2024-10-25 Zookeeper集群搭建及原理 zookeeper集群主要有哪三种角色
- 2024-10-25 Kafka架构和原理机制(图文全面详解)
- 2024-10-25 玩了分布式这么久,你不会连Kafka都不清楚吧
你 发表评论:
欢迎- 最近发表
-
- 吴谨言专访大反转!痛批耍大牌后竟翻红,六公主七连发力显真诚
- 港股2月28日物业股涨幅榜:CHINAOVSPPT涨1.72%位居首位
- 港股2月28日物业股午盘:CHINAOVSPPT涨1.72%位居首位
- 港股3月2日物业股涨幅榜:CHINAOVSPPT涨1.03%位居首位
- 港股3月2日物业股午盘:CHINAOVSPPT涨1.03%
- 天赋与心痛的背后:邓鸣贺成长悲剧引发的深刻反思
- 冯小刚女儿徐朵追星范丞丞 同框合照曝光惹人羡,回应网友尽显亲民
- “资本大佬”王冉:51岁娶小17岁童瑶,并承诺余生为娇妻保驾护航
- 港股3月2日物业股午盘:CHINAOVSPPT涨1.03%位居首位
- 「IT之家开箱」vivo S15 图赏:双镜云窗,盛夏风光
- 标签列表
-
- oraclesql优化 (66)
- 类的加载机制 (75)
- feignclient (62)
- 一致性hash算法 (71)
- dockfile (66)
- 锁机制 (57)
- javaresponse (60)
- 查看hive版本 (59)
- phpworkerman (57)
- spark算子 (58)
- vue双向绑定的原理 (68)
- springbootget请求 (58)
- docker网络三种模式 (67)
- spring控制反转 (71)
- data:image/jpeg (69)
- base64 (69)
- java分页 (64)
- kibanadocker (60)
- qabstracttablemodel (62)
- java生成pdf文件 (69)
- deletelater (62)
- com.aspose.words (58)
- android.mk (62)
- qopengl (73)
- epoch_millis (61)
本文暂时没有评论,来添加一个吧(●'◡'●)