小编Pis*_*olo的帖子

我想序列化来自JSON对象的数据,并通过网络将其发送到kafka作为结束.现在我在一个文件中有一个avro模式,它确定了为日志记录系统发送到kafka所需的字段:

{"namespace": "com.company.wr.messages",
   "type": "record",
   "name": "Log",
   "fields": [
       {"name": "timestamp", "type": "long"},
       {"name": "source", "type": "string"},
       {"name": "version", "type": "string"},
       {"name": "ipAddress", "type": "string"},
       {"name": "name", "type": "string"},
       {"name": "level", "type": "string"},
       {"name": "errorCode", "type": "string"},
       {"name": "message", "type": "string"}
       ]
}

我正在使用节点包'avro-schema',我尝试了其他的但是当时没有一个工作得很好,我只需要从节点js以avro方式序列化.