Kafka3.x安装以及使用

news2024/11/25 8:21:58

一、Kafka下载

下载地址:https://kafka.apache.org/downloads
在这里插入图片描述

二、Kafka安装

因为选择下载的是 .zip 文件,直接跳过安装,一步到位。
选择在任一磁盘创建空文件夹(不要使用中文路径),解压之后把文件夹内容剪切进去(本人选择 D:\env-java\路径下,即完成安装)。
linux解压命令tar -zxvf kafka_2.13-3.5.1.tgz,linux环境下指令是在\kafka_2.13-3.5.1\bin目录。
windows直接解压即可,windows环境下指令是在kafka_2.13-3.5.1\bin\windows目录。
注意:不同系统指令所在的目录不同。
执行命令当前目录D:\env-java\kafka_2.13-3.5.1

修改 kafka-server 和zookeeper配置

进入到目录:kafka_2.13-3.5.1/config/server.properties以及kafka_2.13-3.5.1/config/zookeeper.properties

  • linux系统:
broker.id=1
log.dir=/Users/imagetask/kafka-logs

   
   

在这里插入图片描述

  • windows系统:
broker.id=1
log.dirs=/env-java/kafka_2.13-3.5.1/kafka-logs

   
   

在这里插入图片描述
在这里插入图片描述
/:表示当前的根路径,即D盘。没有就会创建对应的文件夹。

三、启动Kafka服务

1、启动ZooKeeper
  • linux系统:
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

   
   
  • windows系统:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties	

   
   
2、启动kafka
  • linux系统:
bin/kafka-server-start.sh config/server.properties

   
   
  • windows系统:
bin\windows\kafka-server-start.bat config\server.properties

   
   

四、Kafka的使用

1、创建主题
  • linux系统:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

   
   
  • windows系统:
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

   
   
2、删除主题
  • linux系统:
bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test

   
   
  • windows系统:
bin\windows\kafka-topics.bat --delete --bootstrap-server localhost:9092 --topic test

   
   
3、查看Topic 列表
  • linux系统:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092

   
   
  • windows系统:
bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

   
   
4、启动 Producer
  • linux系统:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

   
   
  • windows系统:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

   
   
5、启动 Consumer
  • linux系统:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

   
   
  • windows系统:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

   
   
6、查看Topic 相关信息(test)
  • linux系统:
bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test

   
   
    • windows系统:
    bin\windows\kafka-topics.bat --describe --bootstrap-server localhost:9092 --topic test
    
       
       

    本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1123163.html

    如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

    相关文章

    10个最流行的开源机器视觉标注工具

    推荐:用 NSDT编辑器 快速搭建可编程3D场景 我们知道寻找良好的图像标记和注释工具对于创建准确且有用的数据集的重要性。 随着图像注释空间的增长,我们看到开源工具的可用性激增,这些工具使任何人都可以免费标记他们的图像并从强大的功能中受…

    这5种炫酷的动态图,都是用Python实现的!

    数据可以帮助我们描述这个世界、阐释自己的想法和展示自己的成果,但如果只有单调乏味的文本和数字,我们却往往能难抓住观众的眼球。而很多时候,一张漂亮的可视化图表就足以胜过千言万语。本文将介绍 5 种基于 Plotly 的可视化方法&#xff0c…

    IP地址SSL证书 IP证书

    在许多企业用例中,公司需要SSL证书作为IP地址。公司使用IP地址通过Internet访问各种类型的应用程序。 公网IP地址的SSL证书: 内部IP(也称为私有IP)是IANA设置为保存的IPv4或IPv6地址,例如: RFC 1918范围内…

    编译原理如何写出不带回溯的递归子程序?

    递归子程序 使用不带回溯的递归子程序解析文法是预测性语法分析的基础,这通常需要该文法是LL(1)文法。每个非终结符对应一个递归子程序,并使用当前的输入符号和FIRST集合来决定调用哪个产生式。 让我们以一个简单的文法为例: 对于此文法&am…

    大模型开发06:LangChain 概述

    大模型开发06:LangChain 概述 LangChain 是一个基于语言模型开发应用程序的框架。它可以实现以下功能: 上下文感知: 将语言模型与上下文源相连接(提示词、示例、用于支撑响应的内容等)推理能力: 依赖语言模型进行推理(如何根据提供的上下文来回答问题或采取哪些行动等)La…

    抖音手把手带,开放到月底!

    这个月一直在做的两件事,一个是带内部社员,去把抖音项目跑通。一个是招募合伙人。简单说下这两个事,之前一直没在公众号说。 带学员这件事,默认收徒只到月底。感兴趣的直接报名,价格4980。这块无需多言,做一…

    如何解散微信群?这两个方法收藏好!

    微信群,简单来说就是多人社交,能够让用户与多个人进行交流与互动。群主可以邀请有共同爱好的朋友在一个群里聊天、分享信息等等,以此来增强社交互动。 如果是一些临时活动群或者群成员已经不活跃的情况下,那么群主可能会选择将群…

    mysql图片存取初探

    mysql数据库中使用blob存储使用base64加密图片数据 前言 这个方法并不好,因为传输的数据量还是蛮大的,可以存一些诸如头像的小图片,但是如果要存较大的图片会很慢。 不过只是课程作业中简单的功能,这样子简单又快捷,…

    各类深度学习框架详解+深度学习训练环境搭建-GPU版本

    目录 前言 一、深度学习框架 TensorFlow PyTorch Keras Caffe PaddlePaddle 二、深度学习框架环境搭建 1.CUDA部署 CUDA特性 CUDA下载 2.cuDNN cuDNN 的主要特性 cuDNN 下载 3.安装TensorFlow框架 TensorFlow 2 旧版 TensorFlow 1 4.安装PyTorch框架 5.安装Ca…

    MySQL字段加密方案 安当加密

    要通过安当KSP密钥管理系统实现MySQL数据库字段的加密,您可以按照以下步骤进行操作: 安装和配置安当KSP密钥管理系统:首先,您需要安装安当KSP密钥管理系统,并按照说明进行配置。确保您已经正确地设置了密钥管理系统的用…

    数据结构与算法之图: Leetcode 417. 太平洋大西洋水流问题 (Typescript版)

    太平洋大西洋水流问题 https://leetcode.cn/problems/pacific-atlantic-water-flow/description/ 描述 有一个 m n 的矩形岛屿,与 太平洋 和 大西洋 相邻。 “太平洋” 处于大陆的左边界和上边界,而 “大西洋” 处于大陆的右边界和下边界。 这个岛被…

    Elsevier上传LaTeX修改稿常见问题解决方法

    在撰写科研论文时,一般会使用latex或者word两种工具。在论文的返修阶段,很多期刊要求我们上传可编辑格式的稿件。word在上传到爱思唯尔系统中时候很方便,但latex是较为麻烦的,下面和大家分享一下我在上传latex手稿时遇到的一些问题…

    【人工智能】LLM 大型语言模型和 Transformer 架构简介

    目录 大型语言模型 (LLM) 一、LLM的起源 二、LLM的发展阶段 三、LLM的应用领域

    torch.nn.Parameter()

    一文通俗理解torch.nn.Parameter() 一、起源 首先,我写这篇文章的起源是因为,我突然看到了一段有关torch.nn.Parameter()的代码。 因此就去了解了一下这个函数,把自己的一些理解记录下来,希望可以帮到你。 二、官方文档 网址如下…

    单目3D目标检测[基于几何约束篇]

    基于语义和几何约束的方法 1. Deep3DBox 3D Bounding Box Estimation Using Deep Learning and Geometry [CVPR2017]https://arxiv.org/pdf/1612.00496.pdfhttps://zhuanlan.zhihu.com/p/414275118 核心思想:通过利用2D bounding box与3D bounding box之间的几何约…

    直播录屏没有声音?解决方案来了!

    在进行游戏直播、教程制作或在线会议录制时,有声音的录屏是至关重要的。然而,有时用户可能会面临直播录屏没有声音的问题。在本文中,我们将介绍两种常用的方法来解决这个问题,通过遵循下面的步骤,您将能够轻松地添加声…

    Osgb转3DTiles工具

    三维倾斜摄影生产主要格式为Osgb,目前三维模型主要展示场景为web,大部分使用框架都是Cesium库,格式为 3DTiles,目前市面上osgb转3DTiles的软件已经有好几个,付费免费都有。 先说免费软件: 1、CesiumLab …

    SaaS是云计算服务,不是互联网平台

    习惯性的把SaaS云计算服务,理解成平台,是不对的! SaaS本质就是云计算服务,企业在saas应用系统里操作业务,背后都是各种云计算操作。 但是,中国的互联网环境就都是巨头平台所主导,所以大家基本…

    华为OD机试 - 寻找最大价值的矿堆 - 矩阵(Java 2023 B卷 200分)

    目录 专栏导读一、题目描述二、输入描述三、输出描述四、Java算法源码五、效果展示1、输入2、输出 华为OD机试 2023B卷题库疯狂收录中,刷题点这里 专栏导读 本专栏收录于《华为OD机试(JAVA)真题(A卷B卷)》。 刷的越多…

    工具让公众号推送变得轻而易举

    公众号运营的关键在于定期向用户推送内容,但手动推送过程繁琐且浪费时间。现在,有了乔拓云公众号助手工具,你可以轻松实现公众号的自动推送功能。让我们一起来看看如何操作吧! 首先,你需要注册一个乔拓云公众号助手工具…