kafka集群broker频繁挂掉问题解决方案
现象：kafka集群频繁挂掉 排查日志：查看日志文件【kafkaServer.out】，发现错误日志： ERROR Shutdown broker because all log dirs in /tmp/kafka-logs have failed ...
原文：RocketMQ的broker节点挂掉后重启导致的消息重复消费问题解决方案
我的RocketMQ架构图如下： 故障描述： Broker b所在服务器宕机 小时 ： ： ， 重启Broker b后， 小时期间产生的消息被消费者订阅消费， 由于消费者等幂条件是： 小时内相同消息 msgId相同 不重复发送， 但是此时已经超过两小时， 故 : : 期间产生的消息被重复消费。 期望： Broker b重启后， 消费者只订阅当前时间开始的消息， 之前的消息不再订阅。 处理方案 ： ...
2020-11-10 17:21 0 1791 推荐指数：
相关推荐
kafka集群broker频繁挂掉问题解决方案
现象：kafka集群频繁挂掉 排查日志：查看日志文件【kafkaServer.out】，发现错误日志：ERROR Shutdown broker because all log dirs in /tmp/kafka-logs have failed ...
RocketMQ消费者-重复消费的问题解决
重复消费的问题的一个可能的问题：消费者消费消息时产生了异常，并没有返回CONSUME_SUCCESS标志。 重复消费的消息和第一次消费的消息不同，多了一些重复消费的信息：reconsumeTimes=1，2，…10REAL_TOPIC也会是：%RETRY%XXXXX这就是因为消息处理异常导致 ...
stream将list转map时,key重复导致报错的问题解决方案
要将List对象集合转为map集合，可以通过stream流的形式快速实现转换： 异常： 意思为map中出现了重复的key，也就是说通过上述方法转map时，出现重复key并不会出现覆盖的情况，而是再次在map中添加一个重复的key，导致报错。 所以通过stream实现list ...
Linux记录-重启后磁盘丢失问题解决方案
1.df -TH 查看挂载情况 2.fdisk -l 查看磁盘情况 3.blkid 查看磁盘文件系统 4.vim /etc/fstab 加入 /dev/xvdf ext4 defaults 0 0 5.保存重启，查看df -TH ...
KafkaSpout 重复消费问题解决
collector.ack(); 导致kafkaSpout一直认为emitted的数据有问题, 超时之后进行数 ...
程序重启RocketMQ消息重复消费
最近在调试RocketMQ消息发送与消费的Demo时，发现一个问题：只要重启程序，RocketMQ消息就会重复消费。 那么这是什么原因导致的，又该如何解决呢？ 经过一番排查，发现程序使用的RocketMQ客户端版本是3.6.2，而测试环境安装的RocketMQ环境的版本是4.1.0。原来是 ...
RocketMQ 消息发送system busy、broker busy原因分析与解决方案
@ 目录 1、现象 2、原理解读 2.1 RocketMQ 网络处理机制概述 2.2 pair.getObject1().rejectRequest() 2.2.1 isOSPageCacheBusy ...