将Kafka Streams与Avro架构注册表一起使用

本教程将介绍将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架构注册表一起使用的教程就到这里就结束了,希望趣模板源码网找到的这篇技术文章能帮助到大家,更多技术教程可以在站内搜索。

0
没有账号?注册  忘记密码?