Kafka 使用Spring Cloud Stream Binder和Json解析器的Schema Registry

myzjeezk  于 12个月前  发布在  Apache
关注(0)|答案(1)|浏览(181)

我是Kafka的新手,我正在尝试使用schema registry并与spring cloud stream binding consumer集成。我研究了很多,得到了很多参考,但没有真正解决。所以你能帮我解决吗?
我有一个监听INPUT绑定的streamlistener。我也可以有一个spring cloud函数“function”,然后有一个绑定“function-in-0”。我用什么都无所谓,但我希望这个INPUT或“function-in-0”绑定消费者拥有schema registry相关的属性。但无论我在哪个路径传递它们,消费者不能选择我猜,因为当我运行应用程序时,我看到消费者配置没有这些属性。
我尝试以多种方式传递模式属性,如: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
什么都没解决。
您能建议我在哪里传递这些模式注册表配置吗

wz3gfoph

wz3gfoph1#

spring.cloud.stream.kafka.binder.consumerProperties是文档中提到的值,是一个Map。其中的所有键都应该在[]

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

相关问题