本文介紹了將Kafka Streams與Avro架構(gòu)注冊表一起使用的處理方法,對大家解決問題具有一定的參考價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧!
問題描述
我正在尋找使用模式注冊中心的kafka-stream。我有谷歌,但找不到合適的教程。
推薦答案
文檔在此處
https://docs.confluent.io/current/streams/developer-guide/datatypes.html#avro
這是依賴項(xiàng)
<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>
這里有很多示例代碼。并非所有產(chǎn)品都使用Avro
https://github.com/confluentinc/kafka-streams-examples/tree/5.2.1-post/src/test/java/io/confluent/examples/streams
這篇關(guān)于將Kafka Streams與Avro架構(gòu)注冊表一起使用的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,