使用 Spring cloud stream Binder 和 Json 反串行器的 Schema Registry

Schema Registry with Spring cloud stream Binder and Json deserializer

提问人:Rahul 提问时间:11/11/2023 最后编辑:OneCricketeerRahul 更新时间:11/23/2023 访问量:12

问:

我是 Kafka 的新手,我正在尝试使用模式注册表并与 spring 云流绑定消费者集成,我研究了很多,得到了很多参考资料,但没有真正成功。所以你能帮帮我吗

我有一个正在监听 INPUT 绑定的流侦听器。我还可以有一个弹簧云函数“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

一无所获。

您能否通过建议我需要在何处传递这些架构注册表配置来提供帮助

apache-kafka confluent-schema-registry spring-cloud-stream-binder-kafka

评论


答:

0赞 OneCricketeer 11/23/2023 #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