将 Kafka Streams 与 Avro Schema Registry 一起使用

【问题标题】：Use Kafka Streams with Avro Schema Registry将 Kafka Streams 与 Avro Schema Registry 一起使用
【发布时间】：2019-10-24 16:17:30
【问题描述】：

我正在寻求通过模式注册表使用 kafka-stream。我有谷歌，找不到合适的教程。

【问题讨论】：

“要求我们推荐或查找书籍、工具、软件库、教程或其他场外资源的问题对于 Stack Overflow 来说是无关紧要的，因为它们往往会吸引固执己见的答案和垃圾邮件。相反，描述问题以及迄今为止为解决问题所做的工作。”
@Damitha - 有关书籍/工具等的问题将从 stackoverflow 中删除。我想你可以在一些论坛上问这些。

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

【解决方案1】：

文档在这里 https://docs.confluent.io/current/streams/developer-guide/datatypes.html#avro

这是依赖

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-streams-avro-serde</artifactId>
    <version>${confluent.version}</version>
</dependency>

确保添加存储库

    <repositories>
        <repository>
            <id>confluent</id>
            <url>https://packages.confluent.io/maven/</url>
        </repository>
    </repositories>

这里有很多示例代码。并不是所有的都使用 Avro
https://github.com/confluentinc/kafka-streams-examples/tree/5.2.1-post/src/test/java/io/confluent/examples/streams

【讨论】：