腾讯云

文章/答案/技术大牛

发布

社区首页 >问答首页 >rocketmq_exporter采集不到retry topic得消息堆积？

问rocketmq_exporter采集不到retry topic得消息堆积？

提问于 2020-01-06 06:32:19

回答 0关注 0查看 376

看控制台是有堆积的，实际是重试的导致的堆积，但是用go写的rocketmq exporter采集不到这个堆积数，只能采集normal的topic,不能采集到retry和死信的

apache

回答

成为首答用户。去写回答

RabbitMQ消息堆积问题

存储 rabbitmq

当生产者发送消息的速度超过了消费者处理消息的速度，就会导致队列中的消息堆积，直到队列存储消息达到上限。最早接收到的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。

叫我阿杰好了

2022/11/07

1.2K0

TCP滑动窗口消息堆积

ip ping port wireshark 服务端

由此可以判断，客户端一直在发数据，但是服务端处理数据整体慢于客户端发送数据，导致服务端数据积压。

用户5166556

2019/11/26

9010

如何应对RocketMQ消息堆积

rocketmq

很多同学都在使用 RocketMQ 时，经常会遇到消息堆积的问题。这篇文章，我们聊聊消息堆积的概念，以及如何应对消息堆积。

勇哥java实战

2023/10/08

2.6K0

TCP滑动窗口消息堆积bug

ip port telnet wireshark 服务端

由此可以判断，客户端一直在发数据，但是服务端处理数据整体慢于客户端发送数据，导致服务端数据积压。

用户5166556

2019/04/20

1.2K0

遇到了消息堆积，但是问题不大

消息队列 CMQ 版 kafka apache 编程算法

这一篇我们要说的话题是消息的堆积处理，其实这个话题还是挺大的，因为消息堆积还是真的很令人头疼的，当堆积的量很大的时候，这真的是个很暴躁的问题，不过这时候真考验大家冷静的处理问题的能力了

Vincent-yuan

2021/11/04

4560

《RabbitMQ》| 解决消息延迟和堆积问题

rabbitmq

我们在上篇已经说明了如何解决消息丢失的问题，也就是保证了消息的可靠性，那么其余两个问题同样重要，这篇我们将讲述其余两个问题的解决方式~！

蔡不菜丶

2021/11/12

2K0

MQ消息堆积终极解决方案【RabbitMQ】

mq 队列推送消息推送

如果架构中有用到mq，那就不可避免会遇到消息堆积的问题，因为我们没办法保证自己生产和消费永远都是正确的。像我们系统就遇到过很多次消息堆积情况，最严重的一次直接导致mq内存溢出，服务宕机，导致所有的mq消费全部出现异常，下面我就这个问题和童靴们唠叨唠叨。

林老师带你学编程

2020/06/16

4K0

一次 kafka 消息堆积问题排查

kafka 架构设计 java apache

项目中某 kafka 消息组消费特别慢，有时候在 kafka-manager 控制台看到有些消费者已被踢出消费组。

张乘辉

2020/02/13

5.6K0

线上kafka消息堆积，consumer掉线，怎么办？

kafka 笔记客户端日志线程

最近处理了一次线上故障，具体故障表现就是kafka某个topic消息堆积，这个topic的相关consumer全部掉线。

阿丸笔记

2023/10/22

1.1K0

rabbitmq消息队列——"topic型交换器"

rabbitmq

本文介绍了RabbitMQ中Topic Exchange和Direct Exchange的区别以及它们在实际使用中需要注意的事项。同时，还提供了一个使用Topic Exchange的日志系统示例。

用户1141560

2017/12/26

7980

面试题：如何保证消息不丢失？处理重复消息？消息有序性？消息堆积处理？

kafka 消息队列 CMQ 版 apache node.js

当然在剖析这几个问题之前需要简单的介绍下什么是消息队列，消息队列常见的一些基本术语和概念。

Vincent-yuan

2021/11/04

1.8K0

【RabbitMQ】Fanout、Direct、Topic、消息转换器

文件存储

Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

陶然同学

2023/02/24

6380

Retry框架之Guava Retry

数据库 sql

一般在各种业务场景中，为了保持系统稳定，我们都会有相应的重试机制，因为比如说，某个接口某个数据库链接由于网络抖动或者其他因素导致响应失败，这时候直接判定失败或者Mock数据未必是一种优雅的方式，因为这种情况下未必是接口挂掉了或者数据库连不上了，有可能是网络一时的抖动导致的，所以这时候一个优雅的重试机制或许能帮上我们。

黑洞代码

2021/04/08

2.2K0

Retry框架之Spring Retry

spring 腾讯云测试服务

分布式系统调用中，经常存在调用超时/异常的情况，因此需要针对超时的情况进行重试处理。

黑洞代码

2021/04/08

5880

kafka topic消息分配partition规则（Java源码）

kafka

我们知道Kafka 的消息通过topic进行分类。topic可以被分为若干个partition来存储消息。消息以追加的方式写入partition,然后以先入先出的顺序读取。

GreizLiao

2019/09/23

1K0

Spring Retry

其他

　　在我们的业务场景中，经常要调用其他的API来获取信息，比如我们的业务场景需要依赖个人信息来处理，这个时候调用个人信息服务的API，但是由于可能同一时段多方在调用这个服务，可能该服务并发太多，没有及时响应我们的调用，我们的业务就不能执行下去，这个时候我们就需要重试机制了，当然 Spring 已经给我们提供了- Retry。　　

haoming1100

2018/12/13

2.4K0

java retry(重试) spring retry, guava retrying 详解

java spring

转载自 http://blog.51cto.com/9250070/2156431

allsmallpig

2021/02/25

1.5K0

RabbitMQ面试热点

rabbitmq 消息队列 CMQ 版 kafka

消息发送的几种模式 4种交换器类型 Direct Exchange: 直连交换器小结：直连交换器发送消息会根据路由和交换机的绑定关系发送到队列如果交换器名称为"",将使用默认交换器默认交换器不会绑定任何队列，mq会直接把route_key当做queue名称去查找 Fanout Exchange: 分发交换器（扇出交换器）小结: 分发交换器发送消息会分发至所有和其有绑定的队列中，这样消息会被多个消费者

用户8870853

2021/08/30

8730

RabbitMQ面试热点

rabbitmq 消息队列 CMQ 版 kafka

用户1880875

2021/08/26

7840

关于 RocketMQ ClientID 相同引发的消息堆积的问题

apache

首先，造成这个问题的 BUG RocketMQ 官方已经在 3月16号的这个提交中修复了，这里只是探讨一下在修复之前造成问题的具体细节，更多的上下文可以参考我之前写的《RocketMQ Consumer 启动时都干了些啥？》，这篇文章讲解了 RocketMQ 的 Consumer 启动之后都做了哪些操作，对理解本次要讲解的 BUG 有一定的帮助。

SH的全栈笔记

2022/08/17

1.2K0

相似问题

为什么cmq的topic配置订阅者为queue，向topic发送消息无法到达queue？

1570

消息中间件CMQ的topic数量是否有上限？

1830

什么是topic？

21.3K

java 向指定topic发送消息，显示成功但是从kafka读不到，用之前给的那个C的示例却可以？

2413

iOS TRTC音视频，突然采集不到远端音频？

1228

问rocketmq_exporter采集不到retry topic得消息堆积？

回答

为什么cmq的topic配置订阅者为queue，向topic发送消息无法到达queue？

消息中间件CMQ的topic数量是否有上限？

什么是topic？

java 向指定topic发送消息，显示成功但是从kafka读不到，用之前给的那个C的示例却可以？

iOS TRTC音视频，突然采集不到远端音频？

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐