带有Spring云流Binder和Json反序列化器的模式注册表

Question

我是 Kafka 的新手，我正在尝试使用模式注册表并与 spring 云流绑定消费者集成，我已经研究了很多并获得了很多参考资料，但没有真正解决问题。那么你能帮我吗

我有一个流监听器监听 INPUT 绑定。我还可以有一个 Spring Cloud 函数“function”，然后有一个绑定“function-in-0”。 我用什么并不重要 但我希望这个 INPUT 或“function-in-0”绑定使用者具有与架构注册表相关的属性。但无论我通过哪条路径传递它们，我猜消费者都无法选择，因为当我运行应用程序时，我看到消费者配置没有这些属性。

我尝试通过多种方式传递架构属性，例如： spring.cloud.stream.bindings.input.consumer.properties.schema.registry.url

spring.cloud.stream.kafka.streams.bindings.consumer.properties.schema.registry.url

spring.cloud.stream.kafka.streams.binder.consumer.properties.schema.registry.url

什么都没解决。

您能否帮助建议我到底需要在哪里传递这些架构注册表配置

Answer 1

spring.cloud.stream.kafka.binder.consumerProperties

是文档中提到的值，并且是一个地图。里面的所有键都应该在

[]

中

spring.cloud.stream.kafka.binder.consumerProperties[schema.registry.url]=http://localhost:8081

https://cloud.spring.io/spring-cloud-stream-binder-kafka/spring-cloud-stream-binder-kafka.html