java—支持在spring云流绑定中为每个使用者绑定定义spring.json.key.type

im9ewurl 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(370)

在遵循jsonserdeexample之后，我能够将主题中的数据直接消费到我的java对象中。以下属性发挥了所有的魔力

spring.json.key.default.type: com.xxxx.datamapper.domain.FormUUID
 spring.json.value.default.type: com.xxxx.datamapper.domain.FormData

但是，现在我想在一个spring启动应用程序中运行两个流侦听器。为此，我需要为每个使用者绑定提供类似的配置。SpringCloud支持这个吗？
到目前为止，对于第二个流，我必须使用字符串序列化程序，然后使用对象Map器进行Map。这使得应用程序代码与不必要的转换纠缠在一起。

1条答案

该示例在绑定器级别定义serde，您也可以在绑定级别设置它们

spring.cloud.stream.kafka.streams.bindings.foo.consumer.key-serde=
spring.cloud.stream.kafka.streams.bindings.foo.consumer.value-serde=

覆盖活页夹级别的设置。
同样，可以用相同的方法设置serde的属性。

spring.cloud.stream.kafka.streams.bindings.foo.consumer.configuration.spring.json...

您可以在绑定器级别定义serde，也可以在绑定级别定义属性。