Redpanda Console - 流数据管理控制台

news/2025/1/7 3:01:18/文章来源:https://www.cnblogs.com/cyanty/p/18653619

Redpanda Console - 流数据管理控制台

简介

Redpanda是一个与Kafka兼容的流媒体数据平台,该平台具有高性能、操作友好和云就绪性。这家总部位于旧金山的公司成立于2019年,专注于Kafka公司关键任务系统的替代产品。

Redpanda使用C++重写Kafka,与Kafka API完全兼容,可以与所有Kafka流媒体应用程序和工具一起工作,无需更改代码。测试文章表明,Redpanda在尾部延迟(p99.99)方面至少比Kafka高出10倍。

Redpanda Console

Redpanda 官网:Redpanda | The streaming data platform for developers

Redpanda Console(之前称为 Kowl)是一个帮助您轻松管理和调试 Kafka/Redpanda 工作负载的 Web 应用程序。Redpanda Console 使用 go 语言与流数据平台(如Kafka)进行交互,实时获取并刷新最新状态的集群指标数据。

Redpanda Console 可以使用户轻松地查看集群状态、监控性能指标、以及管理主题和分区等。这个控制台旨在简化数据流系统的日常操作,让用户能够更有效地维护和监控他们的集群。

快速开始

docker安装

拉取镜像

# 官方镜像
docker pull docker.redpanda.com/redpandadata/console:v2.8.1

docker运行

docker run -d -p 8080:8080 -e KAFKA_BROKERS=localhost:9092 docker.redpanda.com/redpandadata/console/:v2.8.1

本地安装

你需要在 Redpanda Console 的 Github Releases 页:Releases · redpanda-data/console,

选择适合的版本进行下载并解压到指定文件夹,如 /opt。操作命令如下:

# ubuntu Linux
cd /opt
sudo curl -L -o redpanda_console.tar.gz https://github.com/redpanda-data/console/releases/download/v2.6.0/redpanda_console_2.6.0_linux_amd64.tar.gz
# unzip, get redpanda_console
sudo tar -xzf redpanda_console.tar.gz
# config set
sudo mkdir -p /etc/redpanda
# write config
sudo vim /etc/redpanda/redpanda-console-config.yaml

redpanda-console-config.yaml 配置文件的内容示例如下:

更多参数配置详见:Redpanda Console Configuration

kafka:#Brokers is a list of bootstrap servers with#port (for example "localhost:9092").brokers:- broker-0.mycompany.com:9092- broker-1.mycompany.com:9092- broker-2.mycompany.com:9092

配置完成后,需要设置环境变量,使得 Redpanda Console 执行文件能获取配置文件信息,并启动 Redpanda Console:

# set env
export CONFIG_FILEPATH="/etc/redpanda/redpanda-console-config.yaml"
# /opt/ run console
./redpanda-console

启动成功后,浏览器输入http://<console_ip>:8080访问控制台:

功能展示

集群概览

集群概览模块为用户提供了多个指标的监控,可以帮助用户快速获取集群关键信息:

  • 集群运行状态:显示当前集群的健康状况,帮助用户快速识别问题。
  • 集群存储占用:展示了集群中的数据存储使用情况,便于用户进行存储管理和规划。
  • 集群版本信息:显示当前集群运行的版本,方便跟踪和升级。
  • 在线 Broker 数量:实时显示在线的 Broker 数量,关键指标之一。
  • Topics 和 Replicas 数量:提供 Topics 和 Replicas 的数量信息,帮助用户了解集群的规模和数据复制情况。

Topics

在 Topics 模块中,用户可以查看集群的所有topic总数、分区数、副本数,topic存储占用等关键信息,也可以在页面上操作 创建/删除 指定的Topic:

image-20250105103654228

点击对应的 Topic 后,用户将进入到该 Topic 的详细页面,在这里可以深入了解和操作:

  • 消息列表:浏览和搜索 Topic 中的消息,对于消息的追踪和调试非常有用。
  • 消费者信息:显示当前订阅该 Topic 的消费者和消费者组信息,方便查看各消费者的消费进度。
  • 分区状态:展示每个分区的详细信息,包括 Leader、ISR 等关键指标。
  • 配置信息:列出 Topic 的配置信息,支持在页面修改配置以优化性能或行为。
  • ACL(访问控制列表):管理对 Topic 的访问权限,确保数据安全。

此外,Redpanda Console 支持用户手动创建和发布消息,这对于测试或特定场景下的消息注入非常有价值。

从页面可以看到,Redpanda Console 还支持手动删除消息,删除操作支持指定分区、指定时间戳之前的记录删除(删除操作可以理解为 增加指定Topic或分区的Low Watermark,限制消费者从该Topic或分区中能被消费到的最早消息)。

注意:删除操作是一个软删除,实际数据可能仍然在硬盘上,但对客户端都是不可见的,即使他们请求数据。

Consumer Groups

展示集群中所有的消费者组信息,监控包括消费者组的状态、消费者数量、消费者组的Lag等重要信息:

点击页面的消费者组ID进入详情页,可看到如下的监控信息:

  • 消息者组状态:显示当前消费者组的消费状态,如:稳定消费、准备/完成重分区消费、无消费者消费等。
  • 消费者组订阅topic:显示当前消费者组订阅的Topic,包括各分区的LEO、消费者offset及Lag。
  • 消费者组成员:展示消费者组内的消费者成员。
  • ACL(访问控制列表):管理对 Topic 的访问权限,确保数据安全。

值得一提的是,该页面还支持 编辑消费者组offset 的功能,用户可以在页面手动操作设置相应消费者组的偏移量,支持将消费者组Offset指定为最早、最新或特定时间的Offset操作。需要注意的是,只有不活跃的消费者组(无消费者消费)才可以手动指定偏移量。

总结

综上所述,Redpanda Console 是一款功能强大的流数据管理控制台,它提供了一个简洁直观的用户界面,通过这个界面,用户可以轻松地查看集群状态、监控性能指标、以及管理主题和分区等。

项目仓库地址:

GitHub - redpanda-data/console: Redpanda Console is a developer-friendly UI for managing your Kafka/Redpanda workloads. Console gives you a simple, interactive approach for gaining visibility into your topics, masking data, managing consumer groups, and exploring real-time data with time-travel debugging.

参考文章

Kafka颠覆者Redpanda C轮融资1亿美元|流媒体|c轮融资|应用程序|kafka|redpanda_网易订阅

AutoMQ 生态集成 Redpanda Console

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

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

相关文章

Prometheus+Grafana监控flink任务指标

Prometheus+Grafana监控flink任务指标 前期准备 Prometheus 是一款基于时序数据库的开源监控告警系统,由go语言开发,Prometheus的基本原理是通过HTTP协议周期性抓取被监控组件的状态,任意组件只要提供对应的HTTP接口就可以接入监控。 Grafana 是一款采用Go语言编写的开源应用…

Visual Studio中的C#项目连接本地mysql数据库

一、给项目搭载Mysql连接所需的NuGet包 1.点击visual studio上方导航栏的"工具"选项 2.在下拉框中选中"NuGet包管理器" 3.在展开的侧边栏中选择"管理解决方案的 NuGet 程序包" 4.在新打开的窗口中选择"浏览" 5.搜索框中输入"mysq…

P6822 [PA 2012 Finals] Tax

一个小Trick。很牛的题目!! 直接做可能比较困难,你要考虑一些东西重构一下原图。 这一个题目因为是与边相关的,考虑拆边,拆成两条有向边,那么对于一个点的贡献,我们暴力枚举他的边,两条边的贡献就是取 max。 但这个显然过不了,我们有一种差分建边的方式,按照边权排序…

20241421 《计算机基础与程序设计》课程总结

第一周作业 1.学习了有关专业的技能培养方向 2.对《计算机基础与程序设计》进行了大致的浏览,大概了解了计算机的相关理论知识 3.学习了有关2进制、8进制、10进制、16进制之间的转换第二周作业 1.《计算机科学概论》:第一章向我们介绍了计算机科学这门学科的内容以及其基本概…

[.NET] 单位转换实践:深入解析 Units.NET

在现代软件开发中,准确处理不同单位的转换是一个常见而复杂的需求。无论是处理温度、长度、重量还是其他物理量,都需要可靠的单位转换机制。本文将深入介绍 Units.NET 库,展示如何在 .NET 应用中优雅地处理单位转换。单位转换实践:深入解析 Units.NET 摘要 在现代软件开发中…

卡诺图化简

卡诺图化简 卡诺图(Karnaugh Map,简称K图)是一种用于简化布尔代数表达式的工具。它通过将真值表的值图形化,帮助我们更直观地找到最小项和最大项,从而简化逻辑表达式。 卡诺图的基本概念单元格:每个单元格代表一个布尔变量的可能取值组合。 邻接:两个单元格如果只有一个…

Postman与ElasticSearch交互

为了方便测试,修改ES安装路径下的config/elasticsearch.yml中的安全配置,不使用密钥访问。 以下配置的enabled都改为false # Enable security features xpack.security.enabled: falsexpack.security.enrollment.enabled: false# Enable encryption for HTTP API client conn…

本地搭建ElasticSearch

1:在elastic.co下载安装包 https://www.elastic.co/downloads/elasticsearch windows版本的是个zip包,下载解压缩后可直接通过命令行运行 cd [安装路径]/bin elasticsearch2:配置 默认需要ssl、密码等安全配置,会导致localhost:9200访问失败。可通过以下方式关闭安全配置,…

20241307《计算机基础与程序设计》课程总结

目录 第一节 第二节 教材学习内容总结 C语言程序设计第十三章和第十四章的总结: 第十三章:文件操作文件的打开与关闭 • 使用fopen()函数打开文件,它接受文件名和模式作为参数,返回一个FILE指针。 • fclose()函数用于关闭文件,释放资源。 文件的读取 • fgetc()和getc…

错误记录:[Synth 8-6895] The reference checkpoint

报错详情点击查看代码 [Synth 8-6895] The reference checkpoint E:/Projects/Vivado2023/2.ExampleDesign_my/iic_ms/iic_ms.srcs/utils_1/imports/synth_1/Master.dcp is not suitable for use with incremental synthesis for this design. Please regenerate the checkpoin…

4 跨音速

可以的话请点个赞吧,欧内盖,如果没有大伙支持的话,瓦达西!4 跨音速 基本 升力的基本计算公式为:\(L=\frac{1}{2}\rho_{\infty}V_{\infty}^{2}Sc_{l}\) 对于二维翼型升力系数\(c_l\)而言,它直接和机翼截面几何结构相关,即随翼型弯度增大、厚度-弦长比增大而增大。 ‍ ​​…

CPU负载均衡之WALT

前言 本文继续整理CPU调度WALT相关内容,主要整理如下内容:WALT是什么? WALT 计算? WALT 计算数据如何使用?1. WALT是什么? WALT:Windows-Assist Load Tracing的缩写:从字面意思来看,是以window作为辅助项来跟踪CPU LOAD; 实质上是一种计算方法,用数据来表现CPU当前的…