如何在node.js中反序列化avro模式消息

Question

我正在使用kafka从源接收数据，我正在使用用< code>Node.js编写的消费者应用程序，并使用< code>kafka-node连接到kafka服务器。另一方面，生产者是用< code>Java编写的，他们使用一些kafka流库来产生带有模式的avro消息。我可以接收消息，但它们是avro序列化的，下面是我接收的序列化消息格式-

value: '\u0000\u0000\u0001�H\u0002\u00142020-10-01\u0002\u000e1000001\u0002\u000e2668422\u000202021-06-21T09:34:19.003Z\u0000\u0002\u000e3010985\u0002T83dc24eb6aac\u0002.2021-06-21T09:34:20.453'

我正在尝试反序列化它，但无法使用avsc npm模块，因为avsc只接受缓冲区数据格式。我不确定avro消息数据格式的类型。

我们也有这些消息的模式注册表。因此，我只需要帮助反序列化node.js中的消息。我知道有一个npm模块< code>avsc可以帮助对avro消息进行编码和解码，但它只适用于buffer。请帮助我了解如何在Nodejs中反序列化avro消息。

谢谢！！！

Answer 1

const v8 = require("v8");

const str =
  "<'\u0000\u0000\u0001�H\u0002\u00142020-10-01\u0002\u000e1000001\u0002\u000e2668422\u000202021-06-21T09:34:19.003Z\u0000\u0002\u000e3010985\u0002T83dc24eb6aac\u0002.2021-06-21T09:34:20.453'>";

console.log(v8.deserialize(v8.serialize(str)));
console.log(`${Buffer.from(str, "utf8")}`);