Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

这篇具有很好参考价值的文章主要介绍了Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

Kafka2.8版本才开始自带了Zookeeper,所以注意下版本

kafka官网:https://kafka.apache.org

kafka配置快速入门:https://kafka.apache.org/quickstart

kafka下载页面:https://kafka.apache.org/downloads
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

下载完成后解压到当前目录
修改config下的zookeeper.properties

# dataDir是zookeeper持久化数据存放的目录
dataDir=D:/DevApplication/Kafka/zookeeper/data
# zookeeper日志文件
dataLogDir=D:/DevApplication/Kafka/zookeeper/logs
# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
# 用于限制单个 IP 地址与 ZooKeeper 服务器之间的最大连接数。在 ZooKeeper 集群中,每个客户端到服务端都需要建立一个连接。
# 如果允许过多的连接,则会引起 ZooKeeper 服务器的负载过高,从而影响集群的稳定性和可靠性。
# 因此,通过设置 maxClientCnxns 参数可以有效地控制单个 IP 地址对 ZooKeeper 服务器的连接数量,以保证集群的可靠性和稳定性。
# 默认情况下,maxClientCnxns 的值为 60,这意味着单个 IP 地址最多只能与 ZooKeeper 服务器建立 60 个连接。
# 你可以根据实际需要适当调整这个值,以便更好地满足应用程序的需求。
maxClientCnxns=60

修改config下的server.properties

# 指定Kafka日志和数据保存的地址
log.dirs=D:/DevApplication/Kafka/kafka-logs

进入 /bin/windows 下
使用 cmd 执行 zookeeper-server-start.bat . ./. ./config/zookeeper.properties 启动Zookeeper

启动失败,命令过长,语法不正确
这是因为目录层级太深或者是目录名字太长导致的
将Kafka移到D盘根目录下

1.打开 cmd 执行 zookeeper-server-start.bat . ./. ./config/zookeeper.properties 启动Zookeeper

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

2.打开 cmd 执行 kafka-server-start.bat . ./. ./config/server.properties 启动Kafka

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

3.打开 cmd 执行 kafka-topics.bat --create --topic handsome --bootstrap-server localhost:9092 创建 handsome 主题

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

4.执行 kafka-topics.bat --describe --topic handsome --bootstrap-server localhost:9092 查看 handsome 主题详细信息

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

5.执行 kafka-console-consumer.bat --topic handsome --from-beginning --bootstrap-server localhost:9092 订阅 handsome 主题

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

6.执行 kafka-console-producer.bat --topic handsome --bootstrap-server localhost:9092 向 handsome 主题发送消息

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

7.成功生产并消费消息,成功在Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)

8.创建 startKafka.bat 脚本,双击 startKafka.bat 一键启动Kafka文章来源地址https://www.toymoban.com/news/detail-458315.html

@echo off

set KAFKA_HOME=D:\DevApplication\Kafka\bin\windows

cd %KAFKA_HOME%

start cmd /k "zookeeper-server-start.bat ../../config/zookeeper.properties"

ping -n 4 127.0.0.1 > nul

start cmd /k "kafka-server-start.bat ../../config/server.properties"

到了这里,关于Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 在Windows上搭建Kafka环境的步骤,包括安装Java、下载Kafka、配置Zookeeper和Kafka、启动Zookeeper和Kafka、创建主题和生产者/消费者等

    1. 安装Java Kafka需要Java环境支持。可以从Oracle官网下载JDK,或者使用OpenJDK。 2. 下载Kafka 可以从Kafka官网下载Kafka二进制压缩包。解压后可以看到bin、config、libs等目录。 3. 配置Zookeeper Kafka依赖Zookeeper实现分布式协作。可以使用Kafka自带的Zookeeper,也可以独立安装Zookeeper。 如果使

    2024年02月11日
    浏览(44)
  • kafka内置zookeeper启动失败报错INFO ZooKeeper audit is disabled. (org.apache.zookeeper.audit.ZKAuditProvider)

    寻找资料发现是zookeeper设置参数问题 修改kafka安装目录下config文件中的zookeeper.properties文件 安装目录图片如下 修改如下参数 在文件中添加audit.enable=true

    2024年02月12日
    浏览(114)
  • Mac 安装ZooKeeper+kafka基本使用

    下面ZooKeeper基本介绍: 1、基本功能 ZooKeeper 为分布式系统提供了一种配置管理的服务:集中管理配置,即将全局配置信息保存在 ZooKeeper 服务中,方便进行修改和管理,省去了手动拷贝配置的过程,同时还保证了可靠和一致性。 2、 命名服务 在分布式系统中,经常需要对应用

    2024年02月09日
    浏览(33)
  • kafka3.X集群安装(不使用zookeeper)

    在本专栏的之前的一篇文章《kafka3种zk的替代方案》已经为大家介绍过在kafka3.0种已经可以将zookeeper去掉。 上图中黑色代表broker(消息代理服务),褐色/蓝色代表Controller(集群控制器服务) 左图(kafka2.0):一个集群所有节点都是broker角色,kafka从三个broker中选举出来一个Cont

    2024年02月08日
    浏览(40)
  • Windows安装和使用kafka

    由于kafka依赖jdk和zookeeper,安装kafka之前需要先安装jdk和zookeeper,也可以使用kafka自带的zookeeper。安装jdk可以参考:Windows和Linux安装jdk,此处使用kafka自带的zookeeper,不单独安装。 下面在Windows系统中安装kafka时使用的ip地址是192.168.10.188,这是我自己电脑的ip。 修改zk和kafka的配

    2024年02月01日
    浏览(44)
  • Kafka的安装和使用(Windows中)

    1.安装Kafka 1.1下载安装包 通过百度网盘分享的文件:复制链接打开「百度网盘APP 即可获取」  链接:https://pan.baidu.com/s/1vC6Di3Pml6k1KMbnK0OE1Q?pwd=huan  提取码:huan 也可以访问官网,下载kafka2.4.0的安装文件 1.2解压到“D:”目录下 因为Kafka的运行依赖于 Zookeeper,因此,还需要下并

    2024年02月01日
    浏览(48)
  • Zookeeper和Kafka安装

    1.1 安装JAVA JDK 请参考《Windows环境下JDK的安装》 JDK版本: 1.2 安装ZooKeeper 1、 下载安装包 http://zookeeper.apache.org/releases.html#download 这里下载的版本为 3.4.9 2、 解压并进入ZooKeeper目录: 3、进入 C:zsxsoftwarezookeeper-3.4.9conf , 将 zoo_sample.cfg 复制并且重命名为 zoo.cfg 4、 打开 zoo.cfg

    2024年02月05日
    浏览(35)
  • 安装Zookeeper和Kafka集群

    本文介绍如何安装Zookeeper和Kafka集群。为了方便,介绍的是在一台服务器上的安装,实际应该安装在多台服务器上,但步骤是一样的。 从官网上下载安装包: 解压: 创建目录 zk1 ,然后添加如下配置: zk1/myid : zk1/zk.config : 对于 zk2 和 zk3 也重复同样的步骤,并修改相应的配置

    2023年04月17日
    浏览(31)
  • 【Kafka】Zookeeper和Kafka集群的安装和配置

    一、集群环境说明 1. 虚拟机:192.168.223.101/103/105 2. 系统版本:CentOS 7.9 3. JDK版本:11.0.18.0.1 4. Zookeeper版本:3.7.1 5. Kafka版本:2.13-2.8.2 备注:无论是ZK,还是Kafka的安装,都需要用到JDK,上面给出的ZK和Kafka版本,都已经支持JDK11(JDK 11 Supported)。这三者之间的兼容关系,感兴趣

    2024年02月12日
    浏览(56)
  • 安装kafka需优先安装 zookeeper ,scala

    安装kafka需优先安装 zookeeper , scala scala 安装(如安装略过) 现在 wget https://downloads.lightbend.com/scala/2.12.11/scala-2.12.11.tgz 解压 tar -zxvf scala-2.12.11.tgz 编辑环境变量 vim /etc/profile 添加环境变量 ( export SCALA_HOME=/apps/scala export PATH=${PATH}:${SCALA_HOME}/bin ) 生效配置文件文件   source /etc

    2024年04月29日
    浏览(42)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包