带有 avro 模式注册表的 java kafka 流的正确指南

Question

我正在为带有架构注册表的 java kafka-stream 寻找适当的教程/指南。我有谷歌，但找不到合适的教程。如果有人能帮我找到至少合适的教程，我真的很感激

我可以通过谷歌搜索找到 kafka 流教程。但我正在寻找带有 schemaregistry 的 kafka 流

Answer 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>

确保添加存储库

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

这里有很多示例代码https://github.com/confluentinc/kafka-streams-examples/tree/5.2.1-post/src/test/java/io/confluent/examples/streams