avro_kafka_storm_poc:使用 Schema-Repo 作为模式存储库的 Avro 序列化消息的 Kafka 风...

使用 Avro 数据序列化的 Kafka-Storm 概念验证。 Java 客户端连接到 Schema-Repo 以获取模式并构建序列化消息。 该消息随后发布在 kafka 的 avrotopic 队列中。 已经创建了一个带有 Spout 的拓扑，负责读取发布在队列上的消息，这些消息已经在源头用 Avro 序列化。 稍后它通过 Bolt 再次从 Schema-Repo 存储库中获取架构以重建 JSON 对象。