将Kafka Streams与Avro架构注册表一起使用 [英] Use Kafka Streams with Avro Schema Registry

问题描述

我正在寻找使用模式注册中心的kafka-stream。我有谷歌，但找不到合适的教程。

推荐答案

文档在此处 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

这篇关于将Kafka Streams与Avro架构注册表一起使用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！