记录消息被未知消费者消费bug

bug描述：

测试环境下，目标mq有很多未知消费者，导致消息被未知消费者消费，出现期望的消费者无法收到消息的bug。

产生原因：

经过测试，在win和mac操作系统的情况下，开启消费者服务，并未停止服务，直接关闭idea会导致java进程不被杀死，而在后台继续消费消息，从而产生bug

解决办法：

ps -ef | grep java | grep 你的项目名

得到进程id后，根据进程id kill掉相关进程即可。

记录消息被未知消费者消费bug相关推荐

kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、查看消费者组、更新消费者的偏移位置）
文章目录前言 1. 基础概念 Broker Producer Consumer Consumer Group Topic Partition Replica 2. 命令行操作 2.1 查看所有top ...
mq多个消费者消费一个消息_ActiveMQ多个消费者消费不均匀问题
如果客户端处理很慢的话,Broker会在之前发送消息的反馈之前,继续发送新的消息到客户端.如果客户端依旧很慢的话,没有得到确认反馈的消息会持续增长.在这种情况下,Broker有可能会停止发送消息给消费 ...
Rabbit发送消息，消费者消费异常
Rabbit发送消息,消费者消费异常背景: 在步骤1下创建订单,步骤2下提交消息 @Transactionalpublic void tradeHandler(Map map) {// 1.生成统一 ...
rabbitmq 不同的消费者消费同一个队列_消息队列王者--rabbitMQ深入理解--工作过程、消费模式、持久化等...
概述之前已经对rabbitMQ的一些基本概念做了介绍和不同MQ之间的比较,今天主要对rabbitMQ的一些方面做扩展. 01 消息队列 Broker:简单来说就是消息队列服务器实体. Exchang ...
rabbitmq多个消费者消费同一个队列中的同一条消息。
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录前言一.rabbitmq是什么? 二.使用步骤 1.引入库 2.rabbitmq相关配置 3.生产者代码 4.多个消费者, ...
【消息队列】kafka是如何保证消息不被重复消费的
一.kafka自带的消费机制 kafka有个offset的概念,当每个消息被写进去后,都有一个offset,代表他的序号,然后consumer消费该数据之后,隔一段时间,会把自己消费过的消息的offs ...
videojs如何获取请求消息_中通消息平台 Kafka 顺序消费线程模型的实践与优化
各类消息中间件对顺序消息实现的做法是将具有顺序性的一类消息发往相同的主题分区中,只需要将这类消息设置相同的 Key 即可,而 Kafka 会在任意时刻保证一个消费组同时只能有一个消费者监听消费,因此可 ...
如何保证消息不被重复消费~~~~~(如何保证消息队列的幂等性)
分析:这个问题其实换一种问法就是,如何保证消息队列的幂等性?这个问题可以认为是消息队列领域的基本问题.换句话来说,是在考察你的设计能力,这个问题的回答可以根据具体的业务场景来答,没有固定的答案. 回答 ...
KAFKA SpringBoot2 Nacos 消息异步发送和消费消息（进阶篇）
文章目录一.基础集成 1. 技术选型 2. 导入依赖 3. kafka配置 4. auto-offset-reset 简述 5. 新增一个订单类 6. 生产者(异步) 7. 消费者 8. kafka ...

记录消息被未知消费者消费bug

记录消息被未知消费者消费bug相关推荐

最新文章

热门文章