kafka - windows 10 环境安装kafka-2.8.2单机测试环境

这篇具有很好参考价值的文章主要介绍了kafka - windows 10 环境安装kafka-2.8.2单机测试环境。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。


下载安装包:https://archive.apache.org/dist/kafka/2.8.2/kafka_2.13-2.8.2.tgz


解压:kafka_2.13-2.8.2.tgz,文件夹更名为:kafka

配置:根据需要配置/config/zookeeper.properties 与 /config/server.properties 等配置文件

启动:

1.先启动zookeeper后kafka

# cd kafka\bin\windows
# 当前目录下打开cmd窗口
# zookeeper-server-start.bat  ../../config/zookeeper.properties &

2.再启动kafka
# kafka-server-start.bat  ../../config/server.properties &

[2023-06-06 12:34:30,242] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)

3.默认端口:
  zookeeper端口: 2181
  kafka端口:9092
 

【其他操作】
# cd kafka\bin\windows

1.创建、新增topics 
# kafka-topics.bat  --create  --zookeeper localhost:2181  --replication-factor 1  --partitions 1  --topic {topic-name}
# 比如:kafka_mq_test

2.查看所有topics
# kafka-topics.bat  --zookeeper localhost:2181  --list 
# kafka-topics.bat  --zookeeper 127.0.0.1:2181  --list 

3.删除topic
# kafka-topics.bat --delete  --zookeeper localhost:2181 --topic  {topic-name}

4.生产者功能测试 -  测试的前提是:必须先创建好一个topic
# kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic  {topic-name}
# 示例:>kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic topic2023

5.消费者功能测试
# kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic  {topic-name}  --from-beginning
# 示例:>kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic topic2023 --from-beginning

【Kafka存储机制】

# topic中partition存储分布
# partiton中文件存储方式
# partiton中segment文件存储结构
# 在partition中通过offset查找message

可以借助图形化工具快速具象的查看kafka的消息数据,也能便于理解其基本操作流程:

比如:
  图形化工具:offsetexplorer

  web控制台:kafka manager。


 文章来源地址https://www.toymoban.com/news/detail-598902.html

到了这里,关于kafka - windows 10 环境安装kafka-2.8.2单机测试环境的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

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

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

相关文章

  • hadoop伪分布式集群的安装(不是单机版)

    三台虚拟机,关闭防火墙,关闭selinux 查看防火状态 systemctl status firewalld 暂时关闭防火墙 systemctl stop firewalld 永久关闭防火墙 systemctl disable firewalld 查看 selinux状态 getenforce 暂时关闭 selinux setenforce 0 永久关闭 selinux 在/etc/selinux/config文件中将SELINUX改为disabled   三台主机 根据自己

    2023年04月14日
    浏览(96)
  • 超详细Hadoop安装教程(单机版、伪分布式)

    Hadoop是一个由Apache基金会所开发的分布式系统基础架构。用户可以在不了解分布式底层细节的情况下,开发分布式程序。充分利用集群的威力进行高速运算和存储。 Hadoop的框架最核心的设计就是: HDFS 和 MapReduce 。HDFS为海量的数据提供了存储,而MapReduce则为海量的数据提供了

    2024年02月08日
    浏览(57)
  • Hadoop3.1.3安装教程单机伪分布式配置

    本教程使用 Ubuntu 18.04 64位 作为系统环境(或者Ubuntu 14.04,Ubuntu16.04 也行,32位、64位均可),请自行安装系统。装好了 Ubuntu 系统之后,在安装 Hadoop 前还需要做一些必备工作。 创建hadoop用户 如果你安装 Ubuntu 的时候不是用的 “hadoop” 用户,那么需要增加一个名为 hadoop 的用

    2024年02月04日
    浏览(49)
  • 超详细版Hadoop的安装与使用(单机/伪分布式)

    虚拟机安装包以及Ubuntu ISO映像下载:https://pan.baidu.com/s/19Ai5K-AA4NZHpfMcCs3D8w?pwd=9999  下载完成后,进入VMware,点击右上角【文件】——【新建虚拟机向导】 1.1选择典型 1.2选择光盘映像 映像文件选择上方刚刚下载的ubuntukylin-16.04-desktop-amd64 1.3命名 根据自己需求来,无统一规定

    2024年01月21日
    浏览(52)
  • 基于 kRaft 搭建单机 kafka 测试环境

    使用 docker-compose 在单机搭建有三个节点的 kafka 集群。

    2024年02月14日
    浏览(37)
  • Hadoop(01) Hadoop3.3.6安装教程,单机/伪分布式配置

    在安装 Hadoop 3.3.6 前,需要满足以下前置条件: Java Development Kit (JDK):Hadoop 是用 Java 编写的,因此需要安装并配置适当版本的 JDK。Hadoop 3.3.6 建议使用 JDK 8 或更高版本。确保正确安装 JDK,并设置 JAVA_HOME 环境变量。 SSH:Hadoop 集群中的节点需要通过 SSH 进行通信和管理。确保在

    2024年02月06日
    浏览(45)
  • Hadoop3.3.5云耀云服务器安装教程-单机/伪分布式配置

    华为云耀云服务器试用领取 领取的试用云耀云服务器在哪 阿里云服务器免费试用领取 Hadoop3.3.5云耀云服务器安装教程-单机/伪分布式配置 阿里云服务器ECS安装图形界面 本篇文章是基于上一篇所配置好的云服务器进行实验软件安装,该系列文章是根据林子雨所讲述的课程就在

    2024年01月21日
    浏览(51)
  • 【大数据工具】Kafka伪分布式、分布式安装和Kafka-manager工具安装与使用

    Kafka 安装包下载地址:https://archive.apache.org/dist/kafka/ 1. Kafka 伪分布式安装 1. 上传并解压 Kafka 安装包 使用 FileZilla 或其他文件传输工具上传 Kafka 安装包: kafka_2.11-0.10.0.0.tgz 解压安装包 2. 编辑配置文件 3. 拷贝并修改配置文件 分别修改 server2.properties、server3.properties 4. 创建日志

    2024年02月14日
    浏览(45)
  • Hadoop3.1.3安装教程_单机/伪分布式配置_Hadoop3.1.3/Ubuntu18.04(16.04)

    目录 前言: 一、VMware Workstation 二、Ubuntu系统安装 新建虚拟机 三、Ubuntu系统的配置 四、更新apt 五、安装SSH、配置SSH无密码登陆  六、安装Java环境 七、安装 Hadoop3.1.3 八、Hadoop单机配置(非分布式) 九、Hadoop伪分布式配置 前言:         本篇教程由作者本人进行修改,原教

    2024年02月03日
    浏览(43)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包