文件名称：avro_kafka_storm_poc:使用 Schema-Repo 作为模式存储库的 Avro 序列化消息的 Kafka 风暴电路概念验证
文件大小：13KB
文件格式：ZIP
更新时间：2024-07-06 17:54:08
Java
使用 Avro 数据序列化的 Kafka-Storm 概念验证。 Java 客户端连接到 Schema-Repo 以获取模式并构建序列化消息。 该消息随后发布在 kafka 的 avrotopic 队列中。 已经创建了一个带有 Spout 的拓扑，负责读取发布在队列上的消息，这些消息已经在源头用 Avro 序列化。 稍后它通过 Bolt 再次从 Schema-Repo 存储库中获取架构以重建 JSON 对象。
【文件预览】：
avro_kafka_storm_poc-master
----.gitignore(3KB)
----src()
--------main()
----resources()
--------LPEvent.avsc(2KB)
----kafka-producer-avro.sh(275B)
----pom.xml(12KB)
----README.md(518B)
----run.sh(1KB)
----dependency-reduced-pom.xml(10KB)
----.gitattributes(483B)