Kafka【三】Windows下安装Kafka集群

server/2024/10/22 9:50:55/

前文:Kafka【一】Windows下安装单节点Kafka

① 安装ZooKeeper

D:\创建文件夹kafkacluster,将kafka安装包kafka_2.12-3.6.1解压缩到kafka文件夹。

  • 修改文件夹名为kafkazk
    因为kafka内置了ZooKeeper软件,所以此处将解压缩的文件作为ZooKeeper软件使用。

  • 修改config/zookeeper.properties文件

dataDir=D:/kafkacluster/kafkazk/data
# the port at which the clients will connect
clientPort=2181

kafka_16">② 安装kafka

将上面解压缩的文件复制一份,改名为kafka1,然后修改config/server.properties配置文件:

# kafka节点数字标识,集群内具有唯一性
broker.id=1# 监听器 9091为本地端口,如果冲突,请重新指定
listeners=PLAINTEXT://:9091# 数据文件路径,如果不存在,会自动创建
log.dirs=D:/kafkacluster/kafka1/data# ZooKeeper软件连接地址,2181为默认的ZK端口号 /kafka 为ZK的管理节点
zookeeper.connect=localhost:2181/kafka

kafka1文件夹复制两份,改名为kafka2,kafka3

分别修改kafka2,kafka3文件夹中的配置文件server.properties

  • 将文件内容中的broker.id=1分别改为broker.id=2,broker.id=3
  • 将文件内容中的9091分别改为9092,9093(如果端口冲突,请重新设置)
  • 将文件内容中的kafka1分别改为kafka2,kafka3

在这里插入图片描述

③ 封装启动脚本

① 在kafkazk文件夹下创建zk.cmd批处理文件

# 添加启动命令
call bin/windows/zookeeper-server-start.bat config/zookeeper.properties

② 在kafka1,kafka2,kafka3文件夹下分别创建kfk.cmd批处理文件

# 添加启动命令
call bin/windows/kafka-server-start.bat config/server.properties

③ 在kafkacluster文件夹下创建cluster.cmd批处理文件,用于启动kafka集群

cd kafkazk
start zk.cmd
ping 127.0.0.1 -n 10 >nul
cd ../kafka1
start kfk.cmd
cd ../kafka2
start kfk.cmd
cd ../kafka3
start kfk.cmd

④ 在kafkacluster文件夹下创建cluster-clear.cmd批处理文件,用于清理和重置kafka数据

cd kafkazk
rd /s /q data
cd ../kafka1
rd /s /q data
cd ../kafka2
rd /s /q data
cd ../kafka3
rd /s /q data

⑤ 双击执行cluster.cmd文件,启动Kafka集群

集群启动命令后,会打开多个黑窗口,每一个窗口都是一个kafka服务,请不要关闭,一旦关闭,对应的kafka服务就停止了。
在这里插入图片描述

如果启动过程报错,主要是因为zookeeper和kafka的同步问题,请先执行cluster-clear.cmd文件,再执行cluster.cmd文件即可。

PS : 输入行太长,命令语法不挣缺的解决办法

  • 使用较短的文件夹和文件的名称
  • 减少文件夹树的深度

http://www.ppmy.cn/server/110305.html

相关文章

Training language models to follow instructionswith human feedback

Abstract 将语言模型做得更大并不会自动提高它们遵循用户意图的能力。例如,大型语言模型可能会生成不真实、有毒或对用户不有帮助的输出。换句话说,这些模型并未与用户对齐(aligned)。本文展示了一种通过人类反馈来对齐语言模型与…

SQL的化身术:使用AS为列或表指定别名

标题:SQL的化身术:使用AS为列或表指定别名 在SQL查询的世界里,别名是一个强大的工具,它允许我们为列或表提供一个临时的名字,以使查询结果更加清晰或简化复杂的查询。AS关键字是指定别名时最常用的方法。本文将深入探…

【Python机器学习】NLP分词——词的“情感”

目录 VADER:一个基于规则的情感分析器 朴素贝叶斯 无论NLP流水线中使用的是单个词、n-gram、词干还是词元作为词条,每个词条都包含了一些信息,这些信息中一个重要部分是词的情感,即一个词所唤起的总体感觉或感情。这种度量短语或…

【逐行注释】容积卡尔曼滤波的MATLAB例程(三维CKF),无需下载,可直接复制代码到MATLAB上运行

文章目录 CKF完整源代码与注释程序运行结果绘图部分误差的统计特性计算与输出部分CKF CKF全称为容积卡尔曼滤波,相比于UKF(无迹卡尔曼滤波),拥有更合理的理论推导和鲁棒性,且在理论上比UKF的精度更高。 另有: 与EKF的对比程序:https://blog.csdn.net/callmeup/article/…

P1004 [NOIP2000 提高组] 方格取数

将先后两次路线当作一次走两条路&#xff0c;路线可以重复&#xff0c;但价值只能计数一次 k i1 j1 i2 j2 以下分别对每一步作了详细的注释 #include <iostream> #include <algorithm>using namespace std; const int N 10 9;int n,m; int g[N][N]; int f[2…

【GPT】Coze使用开放平台接口-【6】Dify 也来一遍

前面讲了 coze 的相关用法&#xff0c;这边想着用 Dify 也来一遍&#xff0c;刚开始的时候接触的是 Dify&#xff0c;后面才是 coze。Dify 和 coze 的侧重点不同&#xff0c;我个人是更倾向用 Dify 构建工作流就可以了&#xff0c;coze 还是相对全能。 本节用 Dify 也会创建插…

【原型模式】

原型模式 Prototype Pattern 属于创建型模式是指原型实例指定创建对象的种类&#xff0c;并且通过拷贝这些原型创建新的对象&#xff0c;调用者不需要知道任何创建细节&#xff0c;不调用构造函数关键点&#xff1a;不通过 new 关键字&#xff0c;而是通过方法去创建对象 原型模…

WHAT - 通过 react-use 源码学习 React(Lifecycles 篇)

目录 一、官方介绍1. Sensors2. UI3. Animations4. Side-Effects5. Lifecycles6. State7. Miscellaneous 二、源码学习示例&#xff1a;n. xx - yyLifecycles - useEffectOnceLifecycles - useEventLifecycles - useLifecyclesLifecycles - useMountedState & useUnmountPr…