从另一个监听器内部调用重试监听器，维护整个重试逻辑

Question

我们使用的是spring-kafka-2.2.8.release。我有一个需要帮助的具体情况。我有4个主题topic、retryTopic、Successstopic和ErrorTopic。如果topic失败，则应该重定向到retryTopic，在那里将进行3次重试尝试。如果这些尝试失败，则必须重定向到ErrorTopic。如果在topic和retryTopic上都有sucess，则应该重定向到sucestopic。基于如何使用spring kafka Version2..2重试的问题，已经实现了这种情况。但是现在，我有了一个新的情况，我需要根据业务逻辑错误从主题侦听器内部调用retryTopic侦听器，而不抛出异常（当抛出异常时，它已经调用了retryTopic，并且必须保持这种行为）。我还需要知道retryTopic在哪个重试尝试号上被调用，作为侦听器bellow的paramater。

 @KafkaListener(id = "so60172304.2", topics = "retryTopic")
 public void listen2(String in) {
            RetryTemplate retryTemplate = new RetryTemplate();
    retryTemplate.execute(new RetryCallback<Void, RuntimeException>() {
        @Override
        public Void doWithRetry(RetryContext retryContext) throws RuntimeException {
             // Can I get the retry count here? It didn't work
             Integer count =RetrySynchronizationManager.getContext().getRetryCount());
            return this.doWithRetry(retryContext);
        }
    }); 
  }

Answer 1

没有理由不能从一个监听器调用另一个监听器（但是除非在第一个方法中使用RetryTemplate调用，否则不会重试）。

如果使用容器工厂上配置的RetryTemplate进行重试（而不是在2.3.x及更高版本中向SeekTocurEnterrorHandler添加backoff)，则可以获得重试计数（从零开始），如下所示...

@KafkaListener(id = "so60172304.2", topics = "retryTopic")
public void listen2(String in) {
    int retryCount = RetrySynchronizationManager.getContext().getRetryCount();
    ...
}

getContext()将返回null（除非您将调用封装在retrytemplate.execute())中）。

在2.5.x中，即使在容器工厂中使用SeekTocurEnterrorHandler和backoff，而不是使用RetryTemplate，传递尝试头也是可用的（可选）。