本教程将介绍将Kafka Streams与Avro架构注册表一起使用的处理方法,这篇教程是从别的地方看到的,然后加了一些国外程序员的疑问与解答,希望能对你有所帮助,好了,下面开始学习吧。
问题描述
我正在寻找使用模式注册中心的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架构注册表一起使用的教程就到这里就结束了,希望趣模板源码网找到的这篇技术文章能帮助到大家,更多技术教程可以在站内搜索。