程序员经验分享-hwhale

kafka的安装与使用（一）

2023-05-16

kafka的安装与使用（一） 

	最近接触消息中间件，把使用过程中记录一下！

1. 下载与安装

	任何文档都要以官方文档为准，英文多看两眼你会发现比上次更加熟悉了。(*￣︶￣)！
	首先附上官方文档：[kafka官网](https://kafka.apache.org/documentation/#quickstart)

注意：kafka需要JDK1.8以上的版本，并且环境要配置好，不懂得可以去百度一个。windows和linux的java环境配置教程；
下载kafka：本文是以【kafka_2.13-2.4.1】和windows环境演示为例，不同的版本后面的代码可能存在小问题，具体的问下度娘可以解决，下载下来后自己找个目录解压出来即可！我这解压后如下图：
解压后的图片
新建一个data目录即可，然后进入config目录，打开：zookeeper.properties 文件找到dataDir=“配置的data目录”，我这是D:/lyxl/kafka_2.13-2.4.1/data，保存关闭。如下图：
zookeeper.properties
接着打开server.properties配置下日志的路径：找到log.dirs=“日志存放的路径”；
server.properties
到此安装配置基本完成！

2. 简单使用

使用命令框进入kafka目录：
注意：windows要进入bin下面的windows路径，运行对应的bat文件，linux则在bin下运行sh文件就行。
下面所有的命令都是在下面这个路径下运行。

cd D:\lyxl\kafka_2.13-2.4.1\bin\windows

启用zookeeper
开启第一个命令窗口

zookeeper-server-start.bat ../../config/zookeeper.properties

启用kafka
开启第二个命令窗口

kafka-server-start.bat ../../config/server.properties

创建一个主题来存储您的事件
开启第三个命令窗口

kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092

开始消息发布窗口
继续在第三个命令窗口

kafka-console-producer.bat --broker-list hadoop132:9092,hadoop133:9092,hadoop134:9092 --topic first

开始消息消费窗口
开启第四个命令窗口

kafka-console-consumer.bat --bootstrap-server hadoop132:9092 --topic first

现在就可以在消息发布窗口发送消息，消费窗口接收消息了。如图：
效果图

3. 问题：

创建消费者报错：zookeeper is not a recognized option
原因是：版本不同的问题导致一些语法有变动，百度下就可以解决，小问题！

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

kafka的安装与使用（一） 的相关文章

  • 安装libcxsparse3.1.2报错

    报错显示 xff1a yjq 64 yjq sudo apt get install liblapack dev libsuitesparse dev libcxsparse3 1 2 libgflags dev 正在读取软件包列表 完成

  • 网络技术基础（16）

    一 xff1a M HSRP的实施 1 1 HSRP 应用场景 1 路由器物理接口下 2 路由器逻辑子接口 3 xff5d 多层交换机SVI 接口下 1 2 M HSRP 定义 多组的HSRP xff0c 实际上就是一个接口参与多个HSRP

  • windows enable long environment path

    windows gt gpedit msc gt enter Edit Group Policy gt Local Computer Policy gt Computer Configuration gt Administrative Te

  • OpenMV与stm32，msp432等单片机的串口通讯（已经写好一个识别色块的例程，可直接使用）keil（MDK）

    OpenMV与stm32单片机的串口通讯 已经写好一个识别并使单片机得到色块信息的例程 可直接使用 keil MDK 已经写好一个识别色块的例程可直接使用 识别色块 单片机得到色块的中心坐标cx cy 长和高w h及面积s 直接复制源码使用

  • 树莓派python实现http请求控制海康威视摄像头转动

    由于海康威视sdk只支持x86架构处理器 xff0c 所以官方的 so无论无何也连接不上 xff0c 于是在咨询技术售后后 xff0c 我们选择http的方式发送指令控制摄像头在预设点移动 折腾了一天 xff0c 又是cookie啊 xff

  • 【ubuntu】ubuntu20.04安装ros noetic（亲测有效，附操作步骤）

    ubuntu20 04安装ros noetic xff0c 实力踩坑 xff0c 亲测有效 xff01 xff01 xff01 一 安装ROS neotic步骤第一步 xff1a 换源第二步 xff1a 添加ROS软件源第三步 xff1a

  • 【CMake】CMake构建C++代码（一）

    x1f449 博 主 x1f448 xff1a 米码收割机 x1f449 技 能 x1f448 xff1a C 43 43 Python语言 x1f449 公众号 x1f448 xff1a 测试开发自动化 x1f449 专 注 x1f448

  • UrlEncode C源码

    urlencode是一个函数 xff0c 可将字符串以URL编码 xff0c 用于编码处理 URL编码 URL encoding xff0c 也称作百分号编码 Percent encoding xff0c 是特定上下文的统一资源定位符 UR

  • OSPF详解（5种包和状态机）

    1 OSPF的数据包 xff08 5种 xff09 Hello xff1a 发现建立并周期保护邻居关系 DBD xff1a 数据库描述包 进行主从关系的选举 xff0c 最重要的作用是发送LSDB目录 LSR xff1a 链路状态请求 对收

  • BGP—origin属性的应用

    BGP origin属性 1 origin 是公认必遵属性 公认必遵 xff1a 只要不人为修改 xff0c 该属性就不会自己改变 origin属性描述该路由是如何成为BGP路由的 符号作用i通过network生成的BGP路由 xff1f

  • MPLS-虚拟专用网 实验（分支之间可以互通）

    1 MPLS V P N实验 xff08 分支之间可以互通 xff09 实验要求 xff1a 1 A1和A2可以通过MPLS V P N打通 xff0c B1和B2可以打通 xff0c A不能访问B 2 R2为ISP 3 R6可以telne

  • vmware ESXi中安装windows11（解决VMware安装Windows11报错+win11跳过联网操作）

    文章目录 vmware ESxi 安装windows111 安装步骤2 Vmware安装win11报错解决方案2 1 问题产生原因 xff1a 2 2 解决方案 xff1a 3 Windows11安装过程中跳过联网操作 xff08 在无法连

  • python 修改ip地址

    安装包 pip install wmi pip install pywin32 实现 import wmi Obtain network adaptors configurations nic configs 61 wmi WMI Win3

  • Postman前置脚本-全局变量和环境变量

    全局变量和环境变量 61 61 全局变量和环境变量 61 61 Postman 请求前置脚本时间戳案例工作原理 全局变量和环境变量 全局变量 概念 xff1a 在 Postman 全局生效的变量 xff0c 全局唯一 设置 xff1a 代码

  • kubernetes❀集群环境搭建

    kubernetes 集群环境搭建 2 kubernetes集群环境搭建2 1 前置知识点2 2 kubeadm 部署方式介绍2 3 安装要求2 4 最终目标2 5 准备环境2 6 环境初始化2 6 1 检查操作系统的版本2 6 2 主机名

  • kubernetes❀资源管理

    kubernetes 资源管理 3 资源管理3 1 资源管理介绍3 2 YAML语言介绍3 3 资源管理方式3 3 1 命令式对象管理3 3 2 命令式对象配置3 3 3 声明式对象配置 3 资源管理 3 1 资源管理介绍 在kuberne

  • Kubernetes❀实战入门

    Kubernetes 实战入门 4 实战入门4 1 Namespace4 1 1 查看 4 1 2 创建 4 1 3 删除 4 1 4 配置方式 4 2 Pod4 2 1 创建并运行4 2 2 查看pod信息4 2 3 访问Pod4 2 4

  • Qt重定向问题

    概念 在我们使用软件时大多使用release版本 xff0c 这样在使用过程中的调试信息就不会显示出来 xff0c 为了将调试信息打印在界面上或者放在文件中保存起来我们就可以使用重定向的技术 在QT的帮助文档 xff1a qInstallM

  • VSUDP通信

    好久没弄VS的UDP通信了 xff0c 使用方式都忘记的差不多了 今天遇到了正好学习一下 UDP理论 xff1a UDP参考链接 xff1a socket函数 为了执行网络输入输出 xff0c 一个进程必须做的第一件事就是调用socket函

  • sockaddr_in结构体的说明（成员：sin_family、sin_addr、sin_zero）

    sockaddr in是系统封装的一个结构体 xff0c 具体包含了成员变量 xff1a sin family sin addr sin zero 这个结构体被封装在ws2def h中 xff0c 具体的代码如下 xff1a typedef

随机推荐

热门标签