我正在寻求 kafka-stream 与 schema-registry 的使用。我有谷歌,但找不到合适的教程。
最佳答案
文档在这里 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
关于java - 将 Kafka Streams 与 Avro 架构注册表结合使用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56523420/