我想知道Spring Kafka如何处理分配给一个实例的多个分区的重试。Spring Kafka是否会根据重试策略和退避策略不断重试相同的消息，还是会重试，在重试之间，是否会从其他分区发送消息？是行为： A)重试消息->重试消息->重试消息 B)重试消息-> other消息->重
浏览 61提问于2019-04-26得票数 0
回答已采纳
如果使用带状态重试的SeekToCurrentErrorHandler，这样每次重试时都会从代理轮询消息，那么在很长的重试周期内，使用者组重新平衡可能会导致分区被重新分配给另一个使用者。举个例子，如果重试最大周期是24小时，但消费者组重新平衡平均每12小时发生一次，则重试永远不会完成，一旦超过保留期，消息(以及消息后面的消息)将最终从主题过期。(假设此时未解决可重试异常的原因)。消息不会像预期的那样
浏览 33提问于2021-10-10得票数 0
回答已采纳
如何实现本文中提到的延迟重试消息模式。我不想丢失死信队列中的消息，也希望使用backoff重试。一旦重试次数耗尽，我希望消息在DLQ中排队。堆栈溢出时也有类似的请求，但根据解决方案，它将在dlq-ttl到期后不断重试。此外，我不希望在重试尝试耗尽后丢失来自DLQ的消息。
浏览 1提问于2018-08-03得票数 0
假设我的消息被放到重试队列中(谁创建了重试队列？它是WCF还是MSMQ服务？)问:谁在超时后将消息从重试队列移动到应用程序队列？消息是否有“已移动”时间戳和“重试”时间戳？
浏览 5提问于2012-01-26得票数 4
回答已采纳
1回答
消息到达队列，并被服务正确地拾取。如果发生异常，则将消息放入重试队列。如果我们浏览到.svc或向主队列发送另一条消息，那么重试消息也会被拾取。因此，基本上消息会被困在重试队列中，直到某些东西再次“启动”站点池。
有没有人遇到过同样的问题？
浏览 2提问于2010-01-06得票数 1
当从RabbitMQ接收消息时，我希望用户Spring重试失败的消息处理。
我是否需要设置requeue=true，以便在多次重试后消息以死信交换告终？重试是否意味着每次处理失败时都将消息发送回队列？
浏览 0提问于2020-10-06得票数 0
1回答
每当我无法处理RabbitMQ中的事件/消息时，我都会存储到MongoDB中，以便进行自动和/或手动重试。问题是如何从MongoDB启用自动重试机制。我如何才能有效地收听MongoDB？在MongoDB中预先存储失败的事件/消息好吗？或者我应该创建错误队列，以便在自动重试失败时将失败的事件/消息推送到MongoDB进行手动重试？还有其他建议吗？我的目的是为失败的RabbitMQ事件/消息设计有效的<em
浏览 15提问于2019-01-10得票数 0
backOffMultiplier="5" useExponentialBackOff="true"我期待着以下结果
消息3 ->第二次重试(30 redeliveryDelay X 5 backoffMultipler) =
浏览 2提问于2016-03-11得票数 0
回答已采纳
1回答
我们计划在我们的应用程序中使用NServiceBus来分派消息。在我们的示例中，每条消息都有timeToLive属性，该属性定义了应该处理该消息的时间段。对于第一次尝试消息处理不成功的情况，我们的计划是将其移动到特定的重试存储(重试队列)，然后在成功处理或timeToLive过期时重试消息(重试之间有一些超时)。如果timeToLive过期，我们计划记录消息内容并丢弃消息。
实际上，这种重试
浏览 2提问于2010-03-15得票数 3
回答已采纳
注册了一个狂犬病消息的异步使用者。没有收到官方建议，如何处理异步使用者操作中的进程异常？
可能需要重试队列消息，将消息重试到具有重试时间限制的队列。
浏览 0提问于2018-11-14得票数 0
我想我试图启动一个已经在运行的频道或其他什么。每当我启动发送器通道时，接收器通道就会进入暂停状态。，并发现了一些关于AdoptNewMCA配置的内容，不确定如何在队列管理器级别设置它。我怎样才能顺利地解决这个问题。仅仅停止并重新启动通道并不能做到这一点。/02/2012 12:38:41 PM - Process(19161.269) User(mqm) Program(amqrmppa) VRMF(7.1.0.0) QMgr(
浏览 3提问于2012-08-03得票数 3
回答已采纳
似乎RedisMqServer的requestTimeOut构造函数参数对消息重试之间的时间没有影响。有没有其他方法来增加消息重试之间的延迟？具体地说，我们希望向消息添加一个属性，该属性将指示如果重试尝试未完成，MessageQueueHandler应忽略该消息的时间。
浏览 12提问于2013-10-01得票数 4
1回答
如果第一次尝试失败，消息传递服务器将同步响应Application，声明消息“正在重试”要重试的消息不能保存在“内存”中，就好像消息服务器掉了一
浏览 0提问于2012-02-12得票数 5
如果有一种方式将消息放回，或取消消费，以便再次尝试。
我可以将它本地存储在数据库中，并创建自己的重试方法来包装它(但为了简单起见，我不喜欢这样做)。
浏览 2提问于2021-06-21得票数 0
回答已采纳
我正在利用SQS提供的重试功能，使用重驱策略，并在max重试时将消息转发到死信队列。我想在每次重试的消息中附加额外的数据，但希望SQS继续管理重试。这个是可能的吗？
浏览 1提问于2018-07-05得票数 1
回答已采纳
在spring云流项目的文档中，我看到的唯一的重试机制是一个退避策略。
是否有方法为每种异常定义不同的重试策略？编辑:我使用Kafka作为消息中间件。
浏览 5提问于2017-07-09得票数 2
回答已采纳
1回答
我已经实现了退避指数重试。因此，基本上，如果有任何异常，我克隆消息，然后通过添加一些延迟将其重新提交到队列中。
浏览 0提问于2020-07-12得票数 1
回答已采纳
jms.redeliveryPolicy.backOffMultiplier=2.0&jms.nonBlockingRedelivery=true&jms.redeliveryPolicy.maximumRedeliveryDelay=180
当队列中只有一条消息抛出异常时当多个消息被放到队列中时，时间会加倍，不是针对每个消息，而是针对队列。我预计最大时间是180秒，但消息1在消息2之后170秒重试，下一条消息在340秒后重试。下一条<
浏览 0提问于2015-01-06得票数 0
假设在处理消息时出现异常，Queue 1将重试消息2次，而Queue 2将重试消息3次。Post重试消息将被发送到死信队列。我观察到，当一条消息被发送到VirtualTopic时，它会同时被传递到两个队列。我正面临一个问题，如果两个队列的使用者都不能成功处理消息。发往Queue 1的消息在重试2次后被移至死信队列。我的期望是Queue 2中的消息会在重试3次后死信
浏览 19提问于2020-07-26得票数 1
我正在为基于Kafka的数据处理管道中的消费者重试提出一个架构。我们正在使用Kafka生产者和消费者，并正在考虑重试主题，如果他们在消费时出错，将发送消息。将会有消费者以一定的节奏运行在这些重试主题上。我们的Kafka消息包含有效负载，该负载具有对象和操作类型(可以是创建/更新/删除)。我们对object_id上的消息进行分区，以确保该对象上的操作是有序的。但
浏览 1提问于2018-07-24得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
