Пользовательский связыватель Spring Cloud Stream со свойствами привязки расширения

Question

Я пишу настраиваемый связыватель для Spring Cloud Streams. Связыватель basi c подключен к Spring Cloud Streams и работает.

Сейчас я пытаюсь создать расширенные свойства привязки. Я пытаюсь следовать шаблону, используемому Kalka Binder, но это что-то вроде черной дыры. Есть ли где-нибудь документация или образец, показывающий, как создать связыватель, поддерживающий свойства привязки расширений.

Я чувствую себя очень близко. Мое расширение ConsumerProperty создается и инициализируется из моего application.yml. Но для них создается другое расширение ConsumerProperty, которое никогда не инициализируется. Это тот, который в конечном итоге передается в мой MessageProducer.

Вот мой образец-связыватель: https://github.com/mburbidg/sample-binder

Answer 1

Реализует ли ваше связыватель интерфейс маркера ExtendedPropertiesBinder?

Код, который клонирует свойства производителя для таких связывателей, здесь .

Если он его реализует , Я бы установил там точку останова, чтобы понять, что происходит.

EDIT

Две проблемы:

1. Вы создаете новый расширенные свойства привязки здесь (связыватель Kafka вставляет фактические свойства здесь ).
2. См. Также KafkaExtendedBindingProperties.getBindings ().