Spring Boot：如何在 spring-kafka 中惯用地配置 Schema Registry Serdes

【问题标题】：Spring Boot: how to idiomatically configure Schema Registry Serdes in spring-kafkaSpring Boot：如何在 spring-kafka 中惯用地配置 Schema Registry Serdes
【发布时间】：2021-02-24 18:29:59
【问题描述】：

是否有在spring-kafka 中配置SpecificAvroSerdes（或任何基于模式注册表的serdes - JsonSchema 和Protobuf）的示例，允许利用一些自动配置（基于yaml 或properties 文件）。

SO 中有一些类似的问题，例如How to use Spring-Kafka to read AVRO message with Confluent Schema registry?

但我想具体谈谈 Kafka Streams serdes 和 Serdes 的声明式配置。

谢谢

【问题讨论】：

标签： avro apache-kafka-streams spring-kafka confluent-schema-registry

【解决方案1】：

看起来 Kafka Streams 可以使用默认的 Serde 进行配置。请参阅StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG 和StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG。

根据 Spring Boot 约定，我们可以从 YAML 文件中提供任意属性：https://docs.spring.io/spring-boot/docs/2.4.0/reference/html/spring-boot-features.html#boot-features-kafka-extra-props

所以，可能你的SpecificAvroSerdes 可以像这样在application.properties 中配置：

spring.kafka.streams.properties[default.value.serde]=io.confluent.kafka.streams.serdes.avro.SpecificAvroSerdes

【讨论】：