RocketMQ中相关Table记录

简介: RocketMQ中相关Table记录

这里所说的Table都是存储在内存中的Table,数据结构都是Map。由于比较多,这里记录一下。通常这些信息有一部分是存储在nameServer中,同时可以看到这些信息在Rocketmq中具备其作用,因此这里整理了一下。

一、topic部分

topicConfigTable 主题配置表
topicQueueMappingTable 主题队列映射表
topicRouteTable 主题路由表
topicQueueTable 主题队列表
topicSubscribeInfoTable 主题订阅信息表
topicPublishInfoTable 主题发布信息表
subscriptionGroupTable 订阅组表
topicStatsTable 主题统计表
topicEndPointsTable 主题点表


二、offset

offsetTable 偏移表
slaveOffsetTable slave偏移表
lmqOffsetTable lmq偏移量表
resetOffsetTable 重置偏移表

三、broker

clusterAddrTable 集群地址表
brokerLiveTable broker存活表
replicaInfoTable 副本信息表
brokerAddrTable broker地址表
brokerVersionTable broker版本表
clusterAddrTable 集群地址表

四、pull

pullRequestTable 拉取请求表
processQueueTable 处理队列表
pullFromWhichNodeTable 拉取从哪个节点表

五、stat

statsTable 统计表
statsItemTable 统计明细表

六、权限

accessKeyTable accessKey表
forbiddenTable 禁止表

七、filter

filterServerTable 过滤服务表

八、config

KVTable  kv配置表

九、Netty

remotingServerTable 远程服务表

十、mq

mqTable mq表
mqLockTable mq锁定表

十一、commitlog

compactionLogTable  压缩日志表

十二、其他表

syncStateSetInfoTable 同步状态设置信息表
faultItemTable
taskTable 任务表
factoryTable 工厂表



相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
1月前
|
消息中间件 监控 Kafka
查询Kafka集群中消费组(group)信息和对应topic的消费情况
查询Kafka集群中消费组(group)信息和对应topic的消费情况
279 0
|
2月前
|
消息中间件 JSON Kafka
实时计算 Flink版操作报错合集之kafka源表没有指定group.id,遇到报错,该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
3月前
|
消息中间件 算法 Java
MQ产品使用合集之RocketMQ 2k万的表 新建索引会锁表吗
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
2月前
|
消息中间件 RocketMQ
消息队列 MQ操作报错合集之无法自动创建topic,该怎么办
在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。
|
存储 消息中间件 数据安全/隐私保护
RocketMq Topic创建和删除
RocketMq Topic创建和删除
4696 0
|
消息中间件 存储 编解码
重新理解RocketMQ Commit Log存储协议
Consumer Queue Offset是连续的吗, Commit Log Offset是连续的吗?今天我们一起重新理解RocketMQ Commit Log存储协议。
371 0
重新理解RocketMQ Commit Log存储协议
|
消息中间件 RocketMQ
|
消息中间件 存储 运维
【kafka原理】kafka Log存储解析以及索引机制
我们在kafka的log文件中发现了还有很多以 __consumer_offsets_的文件夹;总共50个; 由于Zookeeper并不适合大批量的频繁写入操作,新版Kafka已推荐将consumer的位移信息保存在Kafka内部的topic中,即__consumer_offsets topic,并且默认提供了kafka_consumer_groups.sh脚本供用户查看consumer信息。
【kafka原理】kafka Log存储解析以及索引机制
|
消息中间件 Kafka
《kafka面试100例 -6》如果在/admin/delete_topics/中手动写入一个节点会不会正常删除Topic
《kafka面试100例 -6》如果在/admin/delete_topics/中手动写入一个节点会不会正常删除Topic
《kafka面试100例 -6》如果在/admin/delete_topics/中手动写入一个节点会不会正常删除Topic
|
存储 消息中间件 RocketMQ
rocketMq-Topic创建过程
Topic可以理解为在rocketMq体系当中作为一个逻辑消息组织形式,一般情况下一类业务消息会申请一个topic来实现业务之间隔离。 Topic的存储 Topic的实际存储模型 说明:     该图分享自: RocketMQ概念模型     Topic是一个逻辑上的概念,实际上在每个broker上以queue的形式保存,也就是说每个topic在broker上会划分成几个逻辑队列,每个逻辑队列保存一部分消息数据,但是保存的消息数据实际上不是真正的消息数据,而是指向commit log的消息索引。
3985 0