Невозможно создать пользовательский RetryTemplate с помощью @StreamRetryTemplate при использовании нескольких связывателей

Question

Я использую Spring Cloud Stream с несколькими связующими.Я пытался создать пользовательский RetryTemplate, используя @StreamRetryTemplate.Пользовательский компонент RetryTempalte создается, но не внедряется в AbstractBinder.Когда я попробовал с одним связующим веществом, он работает должным образом.

Версия: Greenwich.SR1

Пользовательский фрагмент кода повторной попытки шаблона

@StreamRetryTemplate
public RetryTemplate myRetryTemplate() {
    RetryTemplate retryTemplate = new RetryTemplate();
    SimpleRetryPolicy simple = new SimpleRetryPolicy(4);
    retryTemplate.setRetryPolicy(simple);
    return retryTemplate;
}

application.yml:

server:
  port: 7777
spring:
  cloud:
    stream:
      binders:
        kafka_binder:
          type: kafka
          environment:
            spring:
              cloud:
                stream: 
                  kafka:
                    binder:
                      brokers: localhost:9092
      bindings:
        input:  
          destination: EMPLOYEE-TOPIC-R1-P1
          binder: kafka_binder
          contentType: application/json
          group: so51247113

Answer 1

Выглядит как ошибка для меня; открыть вопрос на GitHub .