RocketMQ订阅关系不一致和不能消费时如何排查?

订阅关系不一致

在这里插入图片描述
调整任意一个实例的订阅关系和另一个保持一致
在这里插入图片描述

消费者不能消费消息

它是最常见的问题之一,也是每个消息队列服务都会遇到的问题
在这里插入图片描述
1.确认哪个消息未消费。在这时消费者至少需要手机消息id、消息key、消息发送时间段三者之一
2.确认消息是否发送成功。可以通过消息id、消息key、消息时间段等任意一个条件在社区提供的
RocketMQ Console查找消息。如果查到消息,说明问题在消费者自身。此时消费者可以做如下检查,确认问题:
2.1 订阅的Topic和发送消息的Topic是否一致,包含大小写一致
2.2 订阅关系是否一致
2.3 消费代码是否抛出了异常,导致没有记录日志
2.4 消费者服务器和Namesrv或者Broker是否网络通畅
3.如果在第二步中没有查到消息,说明生产者没有生产成功。消息没有生产成功的问题可能是生产者自身的问题,
也可能是Namesrv或者Broker问题导致消息发送失败。此时生产者可以做如下检查
3.1 确认生产者服务器与Namesrv或Broker网络是否通畅
3.2 检查生产者发送日志,确认生产者是否被流控
3.3 检查Broker日志,确认Broker是否繁忙
3.4 检查Broker日志,确认磁盘是否已满

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

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

相关文章

HashMap使用静态初始化块添加元素

使用静态初始化块&#xff08;Static Initialization Block&#xff09; 示例代码&#xff1a; import java.util.HashMap; import java.util.Map;public class Main {public static void main(String[] args) {// 使用静态初始化块批量添加元素Map<String, Integer> h…

JVM--- 垃圾收集器详细整理

目录 一、垃圾收集需要考虑的三个事情&#xff1a; 二、垃圾回收针对的区域 三、如何判断对象已死 1.引用计数算法&#xff1a; 2.可达性分析算法 四、引用 五、生存还是死亡&#xff1f; 六、回收方法区 七、垃圾收集算法 1.分代收集理论 2.标记-清除算法 3.标记-复制算…

huggingface库LocalTokenNotFoundError:需要提供token

今天刚开始学习huggingface&#xff0c;跑示例的时候出了不少错&#xff0c;在此记录一下&#xff1a; (gpu) F:\transformer\transformers\examples\pytorch\image-classification>.\run.bat Traceback (most recent call last):File "F:\transformer\transformers\e…

一站式安装对应显卡版本的cuda和torch(windows)

前言 一年前&#xff0c;安装过cuda&#xff0c;觉得并不难&#xff0c;就没有记录。 这次安装还算顺利&#xff0c;就是在找资料的时候&#xff0c;浪费了不少时间 这次就记录下来&#xff0c;方便以后再次安装 总结安装程序&#xff1a; 1、安装python环境 2、安装VS的C环境&…

【机构vip教程】Unittest(1):unittest单元测试框架简介

unittest单元测试框架简介 unittest是python内置的单元测试框架&#xff0c;具备编写用例、组 织用例、执行用例、功能&#xff0c;可以结合selenium进行UI自动化测 试&#xff0c;也可以结合appium、requests等模块做其它自动化测试 官方文档&#xff1a;https://docs.pytho…

机试指南:3-4章

文章目录 第3章 排序与查找(一) 排序1.sort函数&#xff1a;sort(first,last,comp)2.自定义比较规则3.C函数重载&#xff1a;同一个函数名&#xff0c;有不同的参数列表4.机试考试最重要的事情&#xff1a;能把你曾经做过的题目&#xff0c;满分地做出来5.例题例题1&#xff1a…

xtu oj 1162 奇偶校验

题目描述 奇偶校验是一种在通讯中经常使用的&#xff0c;用来确认传输的字节是否正确的手段。 对于一个BYTE(8BIT),我们使用0~6bit来存储数据&#xff0c;称为数据位&#xff0c;第7位存储奇偶校验位。 如果数据位有偶数个1&#xff0c;那么第7位为0&#xff0c;否则为1。现给…

markdown绘制流程图相关代码片段记录

有时候会使用typora来绘制一些流程图&#xff0c;进行编码之类的工作&#xff0c;在网络搜集了一些笔记&#xff0c;做个记录&#xff0c;方便日后进行复习&#xff0c;相关的记录如下&#xff1a; 每次作图时&#xff0c;代码以「graph <布局方向>」开头&#xff0c;如…

kettle--JavaScript脚本日期使用

输入日期为20240216&#xff0c;运行如下代码&#xff0c;结果为true var reportdate parent_job.getVariable("v_reportdate"); var date_type parent_job.getVariable("v_date_type"); var reportdate_freportdate.substr(0,4) "/" report…

P3141 [USACO16FEB] Fenced In P题解

题目 如果此题数据要小一点&#xff0c;那么我们可以用克鲁斯卡尔算法通过&#xff0c;但是这个数据太大了&#xff0c;空间会爆炸&#xff0c;时间也会爆炸。 我们发现&#xff0c;如果用 MST 做&#xff0c;那么很多边的边权都一样&#xff0c;我们可以整行整列地删除。 我…

RK3399平台开发系列讲解(USB篇)U盘等存储类设备

🚀返回专栏总目录 文章目录 一、什么是U盘等存储类设备二、U盘设备传输数据结构三、U盘识别需要打开的宏沉淀、分享、成长,让自己和他人都能有所收获!😄 📢介绍U盘等存储类设备。 一、什么是U盘等存储类设备 USB Mass Storage Device Class(USB MSC/UMS) USB大容量存…

springboot199疫情打卡健康评测系统

疫情打卡健康评测系统设计与实现 摘 要 当下&#xff0c;如果还依然使用纸质文档来记录并且管理相关信息&#xff0c;可能会出现很多问题&#xff0c;比如原始文件的丢失&#xff0c;因为采用纸质文档&#xff0c;很容易受潮或者怕火&#xff0c;不容易备份&#xff0c;需要花…

[AIGC] 了解消息队列事务:保证数据一致性的关键

在分布式系统中&#xff0c;消息队列是一种常见的解耦手段&#xff0c;可以帮助我们简化复杂系统的架构设计&#xff0c;提高系统的可靠性和可扩展性。但是&#xff0c;在使用消息队列时&#xff0c;我们需要注意一个重要的问题&#xff1a;保证数据的一致性。在这篇文章中&…

《剑指 Offer》专项突破 - 面试题 43 : 在完全二叉树中添加节点(两种方法 + C++ 实现)

目录 前言 方法一 方法二 前言 题目链接&#xff1a;LCR 043. 完全二叉树插入器 - 力扣&#xff08;LeetCode&#xff09; 题目&#xff1a; 在完全二叉树中&#xff0c;除最后一层之外其他层的节点都是满的&#xff08;第 n 层有 个节点&#xff09;。最后一层的节点可能…

IO进程-day1

1、使用fgets统计给定文件的行数。 #include<stdio.h> #include<string.h> #include<stdlib.h>int main(int argc, const char *argv[]) {if(argc ! 2){printf("inout file error\n");printf("usage:./a.out srcfile destfile\n");ret…

理德外汇名人故事:全球著名的基金经理——布鲁斯·科夫纳

纽约华尔街&#xff08;wall street&#xff09;是纽约市曼哈顿区南部一条大街的名字&#xff0c;长不超过一英里&#xff0c;宽仅11米。它是美国一些主要金融机构的所在地。两旁是陈旧的摩天大楼&#xff0c;这条街上集中了纽约证券交易所、联邦储备银行等金融机构和美国洛克菲…

深入了解C语言:基础、特性与实践

C语言是一门广泛应用于系统编程和嵌入式领域的高效编程语言。通过深入了解其基础、特性以及实际应用&#xff0c;我们能够更好地掌握这门语言&#xff0c;提高编程技能。在本博客中&#xff0c;我们将探讨C语言的各个方面&#xff0c;从基础概念到高级应用&#xff0c;为读者提…

在golang语言中简单使用protobuf时遭遇go_package困难重重

文章目录 前言编写示例示例初始化编写协议文件内容导出协议文件protoc 和 protoc-gen-go执行导出命令 编写协议使用文件 体会总结 前言 Protobuf&#xff0c;全称Protocol Buffers&#xff0c;是一种由Google开发的用于序列化结构化数据的开源数据交换格式&#xff0c;Golang作…

在UE5中使用体积材质

在平时使用UE的材质设置时&#xff0c;经常会看见Material Domain Volume类型&#xff0c;但是却很少使用。其实该类型可以配合体积雾使用&#xff0c;并制作体积效果以弥补自带雾参数的不足。 操作流程 首先找到场景中的ExponentialHeightFog组件&#xff0c;开启体积雾Volu…

SpringBoot整合Redis实现登录失败锁定功能

文章目录 前言一、为何选择Redis作为账户锁定的存储解决方案&#xff1f;二、代码案例讲解1.引入依赖2.配置文件3.示例代码 总结 前言 在现代的软件开发中&#xff0c;安全性和用户体验是至关重要的方面。特别是在身份验证和授权方面&#xff0c;保护用户账户免受恶意访问是至…