使用avro序列化将整个Json发送到kafka？答案

【问题标题】：Sending Whole Json to kafka with avro serialization?使用avro序列化将整个Json发送到kafka？
【发布时间】：2020-05-03 14:19:37
【问题描述】：

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

谢谢。

【问题讨论】：

使用 Avro，您可以定义数据的结构。而不是以 JSON 格式发送数据；我建议使用 Avro 格式。结帐 https://docs.confluent.io/current/schema-registry/schema_registry_tutorial.html

【解决方案1】：

假设您使用的是架构注册表，当然，您可以从文件中删除空格，然后将其读取为标准输入

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

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

【讨论】：