java - 使用avro序列化将整个Json发送到kafka？

Question

我有一个 json 文件，我想将其内容发送给 Kafka 消费者。kafka 使用 Avro 和一个遵循我要发送的 Json 的模式。所以有没有办法读取 json，然后通过 kafka 发送它的全部内容，而无需先解析 json，然后分别发送所有内容键和值？

谢谢。

标签： javajsondata-structuresapache-kafkaavro

Answer 1

假设您正在使用模式注册表，当然，您可以从文件中删除空格，然后将其作为标准输入读取

kafka-avro-console-consumer  ... < $(cat file.json)

否则，您需要编写自己的生产者才能插入 Avro 序列化程序