消息队列 Kafka 入门篇(二) -- 安装启动与可视化工具

一、Windows 10 环境安装

1、下载与解压

首先,访问Apache Kafka的官方下载地址:
https://kafka.apache.org/downloads

在本教程中,我们将使用kafka_2.13-2.8.1版本作为示例。下载完成后,解压到您的工作目录的合适位置,例如F:\kafka_2.13-2.8.1。
在这里插入图片描述

2、启动Kafka与Zookeeper

(1)启动 zookeeper (kafka 依赖 zookeeper),默认端口 2181

打开 Windows powershell,进入目录\kafka_2.13-2.8.1\bin\windows:

F:\kafka_2.13-2.8.1\bin\windows> .\zookeeper-server-start.bat ..\..\config\zookeeper.properties

在这里插入图片描述
(2) 启动kafka 服务,默认端口 9092
打开 Windows powershell,进入目录\kafka_2.13-2.8.1\bin\windows,找到 kafka-server-start.bat ,

 F:\kafka_2.13-2.8.1\bin\windows> .\kafka-server-start.bat ..\..\config\server.properties

在这里插入图片描述

3.kafka 可视化工具(一)kafkatool

Kafka Tool 是一个用于管理和使用Apache Kafka集群的GUI(图形用户界面)应用程序。它提供了一个直观的用户界面,使用户能够快速查看Kafka集群中的对象以及存储在topic中的消息

(1)kafkatool 安装

点击 下载地址
下载 Windows 对应版本后, 安装并连接本地 kafka
在这里插入图片描述

(2)连接配置 kafka 集群

【注意】需要在 C:\Windows\System32\drivers\etc 下的 hosts 文件中,添加入 kafka 的集群域名
例如,添加如下配置(此处需要根据实际情况配置,配置保存后,需要重启KafkaTools才能读取hosts文件中的内容):

192.168.0.1 kafka1
192.168.0.2 kafka2
192.168.0.3 kafka3

4.kafka 可视化工具(二)kafka manager (CMAK)

Kafka Manager是一个用于管理Apache Kafka集群的工具。它提供了丰富的功能,使用户能够轻松地管理和监控Kafka集群。

  1. 官网地址:https://github.com/yahoo/CMAK
  2. CMAK 最新下载地址:https://github.com/yahoo/CMAK/releases/tag/3.0.0.6
    Windows 10环境
  3. 下载后解压,修改 conf/application.conf

在这里插入图片描述

  1. 在命令行启动 cmak.bat 命令,默认端口为 9000
  .\cmak.bat

注意:启动时可能因版本问题,报以下错误:

命令行太长

解决方法:Kafka 可视化管理工具 CMAK 启动错误 – 命令行太长 问题解决

  1. 浏览器访问:http://localhost:9000/

在这里插入图片描述
点击 cluster ,新增 集群,连接到我们的kafka 服务:
在这里插入图片描述
Kafka 安装包及 可视化工具可以 点此下载

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

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

相关文章

ubuntu下chronyc tracking报文详解

在ubuntu下使用chronyc进行时钟的同步操作,下面是执行chrony tracking返回结果: Reference ID : AC1005E7 (ntpxx) Stratum : 12 Ref time (UTC) : Tue Apr 23 07:24:09 2024 System time : 0.000001974 seconds slow of NTP time Last …

如何在Windows 8/10/11上启用和禁用内置访客帐户?这里提供几种方法

你的Windows上有一个内置的guest帐户,可以帮助计算机上没有帐户的人登录。当然,你可以打开或关闭它。本文将介绍一些在Windows 8/10/11计算机中启用和禁用内置guest帐户的有用方法,供你更好地参考。 如何启用内置来宾帐户 在本地组策略中启…

Django中的事务

1 开启全局的事务 DATABASES {default: {ENGINE: django.db.backends.mysql, # 使用mysql数据库NAME: tracerbackend, # 要连接的数据库USER: root, # 链接数据库的用于名PASSWORD: 123456, # 链接数据库的用于名HOST: 192.168.1.200, # mysql服务监听的ipPORT: 3306, …

面向多源异质遥感影像地物分类的自监督预训练方法

源自:测绘学报 作者:薛志祥, 余旭初, 刘景正, 杨国鹏, 刘冰, 余岸竹, 周嘉男, 金上鸿 摘 要 近年来,深度学习改变了遥感图像处理的方法。由于标注高质量样本费时费力,标签样本数量不足的现实问题会严重影响深层神经网络模型的性能。为解决这一突出矛盾…

Linux防火墙相关命令以及ip白名单配置

Linux防火墙相关命令以及ip白名单配置 firewall防火墙基础命令查看防火墙的服务状态查看防火墙的状态服务的开启、关闭和重启查看防火墙规则端口的查询、开放和关闭重启防火墙 防火墙白名单配置部分参数介绍 firewall防火墙基础命令 查看防火墙的服务状态 systemctl status f…

使用 vllm 本地部署 cohere 的 command-r

使用 vllm 本地部署 cohere 的 command-r 0. 引言1. 安装 vllm2. 本地部署 cohere 的 command-r3. 使用 cohere 的 command-r 0. 引言 此文章主要介绍使用 使用 vllm 本地部署 cohere 的 command-r。 1. 安装 vllm 创建虚拟环境, conda create -n myvllm python…

nn.Embedding, nn.Parameter,nn.linear的区别

还没总结: 先贴上参考帖子: Difference between Embedding formulations Issue #60 lucidrains/vit-pytorch GitHub https://audreywongkg.medium.com/pytorch-nn-parameter-vs-nn-linear-2131e319e463 Differences between nn.Embedding and nn.…

网络安全之CSRFSSRF漏洞(上篇)(技术进阶)

目录 一,CSRF篇 二,认识什么是CSRF 三,实现CSRF攻击的前提 四,实战演练 【1】案例1 【2】案例2 【3】案例3 【4】案例4(metinfo) 一,CSRF篇 二,认识什么是CSRF CSRF&#x…

Diff算法深度剖析:优化DOM操作的关键

React的Diff算法是用于比较新旧虚拟DOM树,以找出需要进行更新的部分。它通过遍历树的节点,并比较节点属性和内容,来确定节点是否需要进行更新。 React的Diff算法采用了一些优化策略,以减少不必要的DOM更新,提高性能。…

程序员过了35岁没人要?“这行越老越香”

程序员35岁失业?参加完OceanBase开发者大会,我又悟了! 周六参加了OceanBase2024 开发者大会的现场,来之前我其实挺忐忑的,我觉得一个数据库产品的发布会,能有什么新鲜的东西? 踏入酒店的那一刻&…

vue 动态改变css样式

文章目录 问题描述 问题描述 大家好!今天是2024年4月26日|农历三月十六,时间过得好快,今天这博文主要动态改变css样式,具体实现效果如下: 在data里面声明一个isShow:true属性,通过isShow显示不同的图片 isS…

RouteRecordRaw

最近在学习并使用typescript,接触到了很多新类型,今天在学习过程中,看到了RouteRecordRaw这个类型,写篇博客记录一下。 RouteRecordRaw RouteRecordRaw 是 Vue Router 4 中新增的一个类型定义。 它是用于定义路由记录的。 在 Vu…

Pinia 深度剖析:Vue.js 应用状态管理的全面指南

一、pinia简介 Pinia 是一个专门为 Vue.js 应用程序设计的状态管理库。它的设计理念是简化状态管理过程,提供一种清晰、可维护的方式来管理应用程序中的数据。 二、安装与创建 1.你可以通过 npm 或者 yarn 来安装 Pinia: npm install pinia # 或者 y…

上位机工作感想-从C#到Qt的转变-2

2.技术总结 语言方面 最大收获就是掌握了C Qt编程,自己也是粗看了一遍《深入理解计算机系统》,大致了解了计算机基本组成、虚拟内存、缓存命中率等基基础知识,那本书确实有的部分看起来很吃力,等这段时间忙完再研读一遍。对于封装…

消消乐算法总结

前言 最近在工作中遇到一个问题,做一个消消乐的demo项目,连续相同数目超过四个后就要消除。我在网上看了很多解决方案,有十字形,横向,纵向,梯形搜索。越看越迷糊。这不是用一个BFS就能解决的问题吗&#x…

linux下tcp/udp协议网络通信接口封装+日志打印对象

目录 引入 代码 log.hpp代码 引入 我们可以把之前写过的代码拿过来整合一下,直接封装出网络套接字的接口 这样之后再使用的话,直接调用接口即可这里写的是tcp协议,也可以修改socket函数里的参数,改为udp协议 代码 #pragma once#include <iostream> #include <stri…

实现 vuereact 混合开发项目步骤-微前端

微前端是一种将多个小型前端应用组合成一个大型应用的架构方式。它允许团队独立开发、测试、部署和维护应用的各个部分。Vue.js 和 React 是两个流行的前端框架&#xff0c;它们可以在同一微前端架构下协同工作。 一、常规流程 1. 项目规划 确定项目的范围和目标。 设计应用的…

Qt:实现TCP同步与异步读写消息

一、异步读写 在 Qt 中实现 TCP 客户端和服务器的同步和异步读写消息涉及使用 QTcpSocket 和 QTcpServer 类。这两个类提供了用于建立 TCP 连接、发送和接收数据的功能。下面是一个简单的示例&#xff0c;演示了如何在 Qt 中实现 TCP 客户端和服务器的同步和异步读写消息&…

ISP比普通的静态代理相比有什么优势?

ISP&#xff08;Internet Service Provider&#xff09;&#xff0c;即互联网服务提供商&#xff0c;是向广大用户综合提供互联网接入业务、信息业务、增值业务的电信运营商。而静态代理则是一个固定不变的代理IP地址&#xff0c;具有稳定性强、兼容性好和管理方便等特点。当我…

深入理解Java消息中间件-Apache Kafka

在数字化时代&#xff0c;数据如同血液一样流动于现代应用的每一个角落。如何高效、可靠地处理这些数据流&#xff0c;成为了构建响应式、可扩展和弹性系统的关键挑战。作为一名专业的Java技术架构师和作家&#xff0c;我将深入分析Apache Kafka这一广泛使用的Java消息中间件解…