具有扩展绑定属性的Spring Cloud Stream定制活页夹

Question

我正在为Spring Cloud Streams编写自定义活页夹。基本的资料夹已挂接到Spring Cloud Streams中并且可以使用。

我现在正在尝试创建扩展的绑定属性。我正在尝试遵循Kalka Binder使用的模式，但有点黑洞。是否有文档或某个地方的示例显示了如何创建支持扩展绑定属性的活页夹。

我感觉非常亲密。我的ConsumerProperty扩展名是从application.yml创建并初始化的。但是他们又创建了另一个ConsumerProperty扩展，并且从未对其进行初始化。那就是最终传递到我的MessageProducer中的那个。

这是我的样品装订器：https://github.com/mburbidg/sample-binder

Answer 1

您的活页夹是否实现了ExtendedPropertiesBinder标记器接口？

为此类活页夹克隆生产者属性的代码是here。

如果确实实现了，我会在此处设置一个断点以了解发生了什么。

编辑

两个问题：

1. 您正在创建新的扩展绑定属性here（Kafka活页夹将注入实际属性here）。
2. 另请参见KafkaExtendedBindingProperties.getBindings（）。