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
目录
相关文章
|
3月前
|
消息中间件 Kafka 流计算
FlinkKafkaConsumer相同group.id多个任务消费kafka问题
当使用FlinkKafkaConsumer消费Kafka时,即使设置了相同的group.id,由于Flink内部管理partition的消费offset,两个程序仍能同时消费所有数据。这与KafkaConsumer不同,后者严格遵循消费组隔离原则,避免重复消费同一分区的数据。Flink为实现exactly-once语义,需要独立管理offset,这导致了上述现象。
|
9月前
|
消息中间件 SQL RocketMQ
RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息
RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息
166 0
|
8月前
|
消息中间件 Java API
消息队列 MQ产品使用合集之遇到"No topic route info in name server for the topic"错误,该如何处理
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
9月前
|
消息中间件 算法 Java
MQ产品使用合集之RocketMQ 2k万的表 新建索引会锁表吗
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
8月前
|
消息中间件 RocketMQ
消息队列 MQ操作报错合集之无法自动创建topic,该怎么办
在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。
302 0
|
存储 消息中间件 数据安全/隐私保护
RocketMq Topic创建和删除
RocketMq Topic创建和删除
5026 0
|
消息中间件 Kafka
为什么kafka 需要 subscribe 的 group.id?我们是否需要使用 commitSync 手动提交偏移量?
Kafka 使用消费者组的概念来实现主题的并行消费 - 每条消息都将在每个消费者组中传递一次,无论该组中实际有多少个消费者。所以 group 参数是强制性的,如果没有组,Kafka 将不知道如何对待订阅同一主题的其他消费者。
330 2
|
消息中间件 存储 编解码
重新理解RocketMQ Commit Log存储协议
Consumer Queue Offset是连续的吗, Commit Log Offset是连续的吗?今天我们一起重新理解RocketMQ Commit Log存储协议。
415 0
重新理解RocketMQ Commit Log存储协议
|
存储 消息中间件 Java
RocketMQ的消息查询
RocketMQ的消息查询
RocketMQ的消息查询
|
存储 消息中间件 算法
RocketMQ Compaction Topic的设计与实现
Compaction Topic 是一种基于 key 的数据过期机制,即对于相同 key 的数据只保留最新值。该特性的应用场景主要为维护状态信息,或者在需要用到 KV 结构时,可以通过 Compaction Topic 将 key-value 信息直接保存到 MQ,从而解除对外部数据库的依赖。快来了解下它的设计与实现原理吧~
427 0
RocketMQ Compaction Topic的设计与实现