win10系统下安装Kafka 的详细步骤

2023-11-18

Win10 系统下要使用Kafka需要经过以下三个步骤:

1.安装JDK(需要安装依赖java JDK)

2.安装zookeeper(资源协调,分配管理)

3.安装Kafka

一、安装 Java SE Development Kit 13.0.1

        下载地址:https://www.oracle.com/technetwork/java/javase/downloads/jdk13-downloads-5672538.html

下载后安装即可

配置环境变量

Java_Home:C:\Java\jdk-13.0.2 

 PATH中添加 :%Java_Home%\bin;%Java_Home%\jre\bin;

 完成以上配置以后,运行cmd命令,出现以下文字,说明配置成功:

 1.运行java    

 

运行cmd

2.运行javac: 

 

 到此jdk安装完成

二、安装Zookeeper

1、下载安装文件:https://archive.apache.org/dist/zookeeper/zookeeper-3.4.10/

2、下载完成后,解压到一个目录:E:\zookeeper

3、conf目录下zoo_sample.cfg重命名为zoo.cfg

4、进入编辑 dataDir=E:\\zookeeper\\data

5、进入文件夹管理员身份运行zkServer.cmd

 6、再打开一个cmd窗口运行 zkCli.cmd

zookeeper安装并启动成功。 

三、Kafka安装

1、 下载安装包

http://kafka.apache.org/downloads

注意要下载二进制版本

2、 解压并进入Kafka目录,我的文件夹:E:\kafka_2.11-2.1.1

3、 进入config目录找到文件server.properties并打开

4、 找到并编辑log.dirs=E:\kafka_2.11-2.1.1\kafka-logs

5、 找到并编辑zookeeper.connect=localhost:2181

6、 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181

7、 进入Kafka安装目录E:\kafka_2.11-2.1.1,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入

 .\bin\windows\kafka-server-start.bat .\config\server.properties

注意:注意:不要关了这个窗口,启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

到此环境准备完毕,就可以开发了

给大家推荐一个kafka可视化工具kafka tool 

下载地址:http://www.kafkatool.com/download.html

安装及使用教程参考

https://www.cnblogs.com/frankdeng/p/9452982.html

 

持续更新:上述安装完成后我发现只能进行单机使用生产者和消费者

为了解决这一问题找了很多方法测试

解决办法:

C:\Windows\System32\drivers\etc文件夹中hosts文件添加一条信息

192.168.0.163       ZQL    --前面是ip,后面是我的主机名

找到kafka文件server.properties添加两条信息

 listeners=PLAINTEXT://0.0.0.0:9092

advertised.host.name=ZQL

再测完成

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

win10系统下安装Kafka 的详细步骤 的相关文章

  • 【零知ESP8266教程】快速入门5-使用按键来控制你的灯

    上节课 我们已经学习了如何制作一个简易交通灯 那么如何去控制一个LED的亮或者灭呢 此次试验采用按键来控制我们的LED 实现LED的简单控制 一 工具原料 电脑 windows系统 ESP8266开发板 micro usb线 LED灯一个
  • 第十四章 kafka专题之日志数据删除策略

    日志数据清理 为了控制磁盘的容量 需要对过去的消息进行清理 1 内部定时任务检测删除日志 默认是5分钟 2 日志清理参数配置 支持配置策略对数据进行清理 以segment为基本单位进行定期清理 当前正在使用的segment不会被清理 启用c
  • Kafka一文懂

    初识 Kafka 什么是 Kafka Kafka 是由 Linkedin 公司开发的 它是一个分布式的 支持多分区 多副本 基于 Zookeeper 的分布式消息流平台 它同时也是一款开源的基于发布订阅模式的消息引擎系统 Kafka 的基本
  • Kafka 顺序消费方案

    Kafka 顺序消费方案 前言 1 问题引入 2 解决思路 3 实现方案 前言 本文针对解决Kafka不同Topic之间存在一定的数据关联时的顺序消费问题 如存在Topic insert和Topic update分别是对数据的插入和更新 当
  • mysql 字符集问题整理

    mysql 字符集问题整理 一直对mysql字符集没有明确的概念 mysql为了方便 设置了各种层级的字符集 最近在移植mat数据库时 顺便把这个问题整理清楚 供参考和学习 文章最后有word版本 有两张图片以及不同文字的颜色区分 首先是M
  • Kafka——集群

    文章目录 集群 1 搭建个集群 2 集群发送消息 3 集群消费 3 1 Procuder 3 2 Consumer 4 消费顺序 集群 对于kafka来说 一个单独的broker意味着kafka集群中只有一个节点 要想增加kafka集群中的
  • kafka + zookeeper下载/安装/使用(超详细)

    kafka是需要zk来支持 所以先下载zk 1 下载安装zookeeper 下载地址 选择不带source的 下载下来解压2次 进入到 D zookeeper apache zookeeper 3 6 1 bin conf 目录下 把zoo
  • ELK配置记录(filebeat+kafka+Logstash+Elasticsearch+Kibana)

    一 简介 elk日志平台 日志收集 分析和展示的解决方案 满足用户对 志的查询 排序 统计需求 elk架构 filebeat 采集 kafka Logstash 管道 Elasticsearch 存储 搜索 Kibana 日志应用 各组件功
  • 作为技术岗位面试官的一些分享

    我在过去的四年里参与了很多公司技术岗位的面试 说实话要看出一个人的综合素质 我还真的做不到 至于其他面试官是否可以 我也不得而知 但我个人感悟是 在面试过程中 面试官更加多的是去匹配和比较 在招聘过程中 企业会根据人力需求先制定出一套招聘需
  • kafka配置内外网访问

    listeners 学名叫监听器 其实就是告诉外部连接者要通过什么协议访问指定主机名和端口开放的 Kafka 服务 advertised listeners 和 listeners 相比多了个 advertised Advertised 的
  • [Docker]使用Docker部署Kafka

    Kafka 是一个分布式流处理平台 它依赖于 ZooKeeper 作为其协调服务 在 Kafka 集群中 ZooKeeper 负责管理和协调 Kafka 的各个节点 因此 要在 Docker 容器中启动 Kafka 通常需要同时启动一个 Z
  • kafka(三)重平衡

    历史文章 kafka 一 kafka的基础与常用配置 文章目录 一 kafka消费者组 二 重平衡 Rebalance 2 1 重平衡触发条件 2 2 重平衡策略 2 2 1 Range 平均分配 2 2 2 RoundRobin 轮询分配
  • 公司实战 ElasticSearch+Kafka+Redis+MySQL

    一 需求 前一段时间公司要进行数据转移 将我们ES数据库中的数据转移到客户的服务器上 并且使用定时将新增的数据同步 在这过程中学到了很多 在此记录一下 二 技术栈 Mysql Redis ElasticSearch Kafka 三 方案 为
  • 【Docker安装部署Kafka+Zookeeper详细教程】

    Docker安装部署Kafka Zookeeper Docker拉取镜像 Docker拉取zookeeper的镜像 docker pull zookeeper Docker拉取kafka的镜像 docker pull wurstmeiste
  • shell脚本,一次性启动kafka集群

    版本centos6 5 64位操作系统 已配置JDK1 8 三个节点 在s121节点上可以免密登录到另外两个节点 另外kafka0 9 0 1的安装目录相同 修改了主机名 并在每个节点的hosts文件中设置了映射 脚本内容 bin bash
  • kafka的新API 得到最新一条数据

    业务的需要 需要得到最新的一条消息从kafka中 但是发现ConsumerRecords 这个对象并没有 get index 这种方式的获取并且只能 iterator 或者增强for 循环这种方式来循环 记录 但是有一个count 可以得到
  • MQ - KAFKA 基础篇

    1 KAFKA的核心组件 API Producer API 它允许应用程序向一个或多个 topics 上发送消息记录 Consumer API 允许应用程序订阅一个或多个 topics 并处理为其生成的记录流 Streams API 它允许
  • C#与Java的不同

    https www cnblogs com Yan3399 p 17324904 html 1 C 对应java中关键字 base super this this sealed final 1 base关键字 对应java super C
  • ySql.Data.Types.MySqlConversionException: Unable to convert MySQL date/time value to System.DateTime

    public DateTime Createtime MySql Data Types MySqlConversionException Unable to convert MySQL date time value to System D
  • 从 MySQL 到 DolphinDB,Debezium + Kafka 数据同步实战

    Debezium 是一个开源的分布式平台 用于实时捕获和发布数据库更改事件 它可以将关系型数据库 如 MySQL PostgreSQL Oracle 等 的变更事件转化为可观察的流数据 以供其他应用程序实时消费和处理 本文中我们将采用 De

随机推荐

  • C#密码复杂性校验(二)

    以下是一个使用正则表达式进行密码复杂性校验的示例代码 using System using System Text RegularExpressions class Program static void Main string args
  • 《Unity Shader入门精要》彩图版免费分享~~~~~

    这书很多地方都要币或者要钱 这里就免费分享了 下面是网盘链接 顺手点个赞或者评论一波呗 下载链接 链接 https pan baidu com s 137Y1nkB6h8HIvKOfwFPnbQ 提取码 f8dw 顺手点个赞 蟹蟹蟹蟹
  • 测试人社区——软件测试技术沙龙分享

    作为软件开发领域中至关重要的一环 软件测试的重要性日益凸显 然而 随着软件测试开发技术的不断发展 软件测试也面临着越来越多的挑战 为了更好地应对这些挑战 测试人社区于2023年3月12日举办了技术沙龙 主题为 探索软件测试前沿技术及最佳实践
  • C++实现UDP可靠传输(一)

    声明 禁止以任何形式转载本文章 本文章仅供个人学习记录与交流探讨 文章中提供的思路只是一种解决方案 代码也并非完整代码 如有需要 请自行设计协议并完成编程任务 食用本文章之前 推荐阅读 C 实现流式socket聊天程序 目录 UDP协议的基
  • TypeError: super(type, obj): obj must be an instance or subtype of type 该错误的一次处理

    我在写maya类的时候遇到 版本python2 7 folder lib mayaclass py base类 A base 类 ui py 其中A继承base ui py文件中内容 python2 7 import imp from fo
  • Java是如何读取和写入浏览器Cookies的

    首先我们认识下什么是cookies cookie实际上是一个存在你硬盘里的数据 但是这些数据很特殊 只能由web应用提交给浏览器帮助存储 并且我们还能读取浏览器存在本地的cookie web应用一般只在cookie中存储一些用户信息等少量且
  • hive sql之将一行中的时间范围转成多行

    一 生成hive 临时表其中date time 包含其实日期和结束日期 with test1 as select A班 as class 2023 03 01 2023 03 14 as date time 100 99 89 as sco
  • CUBEMX+HAL库实现STM32串口(不定长度)收发

    CUBEMX HAL库实现STM32串口接收 不定长度 并发送 首先新建一个CUBEMX工程 选择你自己开发板的芯片型号 设置时钟和串口 设置时钟为72MHZ 设置串口中断 点击小齿轮生成KEIL5的工程 设置工程名称及存放位置 点击Ope
  • Calendar常用的方法的返回结果 获取指定时间点

    Calendar常用的方法的返回结果 public class CalendarText Calendar calendar null Before public void test calendar Calendar getInstanc
  • 和氟西汀类似的备注_氟西汀备注是什么意思 和氟西汀差不多的备注

    氟西汀 这是一个药物名字 是抗郁抑症的药物 这个药物名字也经常用来当做备注名使用 氟西汀备注是什么意思 和氟西汀差不多的备注有哪些 氟西汀备注是什么意思 将对方备注成氟西汀 表示的是对方是驱散自己心中阴霾的阳光 对方是自己活下去的动力 是快
  • Difference between MBCS and UTF-8 on Windows

    I am reading about the charater set and encodings on Windows I noticed that there are two compiler flags in Visual Studi
  • 基于Python Django的公务员考试信息管理系统

    文章目录 1 简介 2 技术栈 3 功能分析 4 功能具体设计 4 1 软件功能模块设计 4 2数据库设计与实现 4 2 1概念模型设计 4 2 2数据库逻辑结构设计 5系统详细设计 5 1系统功能模块 5 2管理员功能模块 六 源码咨询
  • tcpdump抓包对性能的影响

    一直以来 提到这个话题 大家更多的关注的是tcpdump抓包本身的性能 比如能不能应付几十万的pps 能否在万兆网络上自运自如 我们现在知道 这些问题的答案都是否定的 即 不能 因此你应该去关注netmap高性能抓包方案以及DPDK这样的东
  • Linux上配置Jupyter Notebook远程访问

    本身自己机器上安装了太多东西 有点慢 本来也喜欢所有的东西搬到服务上 所以如果能安装一个远程的Jupyter 服务器 用起来就会很方便 记录下自己的安装步骤 1 安装ipython jupyter pip install ipython p
  • 未来简史--读书语句摘录及感悟

    文章目录 摘录 个人感想 摘录 18世纪末的英国哲学家边沁主张 所谓至善就是 为最多人带来最大的快乐 并认为国家 市场和科学界唯一值得追寻的目标就是提升全球的快乐 政治家应该追求和平 商人应该促进繁荣 学者应该研究自然 但不是为了荣耀什么国
  • 在tomcat中发布项目时,用IP地址不能访问项目而用localhost时可以访问成功

    最近在开发项目中 遇到的一个问题是 在 tomcat中发布一个web项目 但是发布成功后 只能用http localhost 8080 fm访问项目 不能用 http 127 0 0 1 8080 fm访问项目 也不能用本地的IP地址访问
  • Request method ‘POST‘ not supported错误和解决方法

    最近使用VUE js开发中遇到了错误Request method POST not supported 字面意思上看是因为前后端没有统一使用POST方法 但是我在本地仔细检查了前端调用方法和后端处理方法 均没有发现有这个问题 最后我发现 问
  • Memcached Redis Membase性能测试对比分析

    最近在在调研分布式缓存 希望后面能够当前改进项目中缓存的使用 这个测试结果可能出乎大家的意料之外哦 测试结果对比分析 单次读写访问Memcached最快 Redis居中 Membase最慢 单次读写Membase和Redis速度比较接近 M
  • 计算机考试如何截屏,教你6种电脑截屏的小技巧-电脑怎么截图

    电脑截屏是我们经常要用到的技能 不仅操作简单而且非常实用 方法也有很多 下面小编总结了6种截屏技巧 供大家选择 分别是以下6种 1 搜狗输入法 2 浏览器 3 截屏软件 4 QQ ctrl ait A 和微信 alt A 5 附件截图工具
  • win10系统下安装Kafka 的详细步骤

    Win10 系统下要使用Kafka需要经过以下三个步骤 1 安装JDK 需要安装依赖java JDK 2 安装zookeeper 资源协调 分配管理 3 安装Kafka 一 安装 Java SE Development Kit 13 0 1