Use Kafka Streams with Avro Schema Registry(将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架构注册表一起使用的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:将Kafka Streams与Avro架构注册表一起使用
基础教程推荐
猜你喜欢
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- 在螺旋中写一个字符串 2022-01-01
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01