如何使用Avro二进制编码器对Kafka消息进行编码/解码？

  • Z时代
  • 2024-01-10
  • 分类：问答

我正在尝试使用Avro来读取和写入Kafka的邮件。有没有人有使用Avro二进制编码器对将放入消息队列中的数据进行编码/解码的示例？

我需要的是Avro而不是Kafka。或者，也许我应该考虑其他解决方案？基本上，我试图在空间方面找到一种更有效的JSON解决方案。刚刚提到了Avro，因为它可以比JSON紧凑。

回答：

我终于想起要询问Kafka邮件列表，并得到以下答复，效果很好。

是的，您可以将消息作为字节数组发送。如果查看Message类的构造函数，您将看到-

def this（bytes：Array [Byte]）

现在，查看生产者send（）API-

def send（producerData：ProducerData [K，V] *）

您可以将V设置为Message类型，将K设置为所需密钥。如果您不关心使用键进行分区，请将其也设置为“消息类型”。

谢谢，Neha

以上是 如何使用Avro二进制编码器对Kafka消息进行编码/解码？ 的全部内容， 来源链接： utcz.com/qa/403474.html

回到顶部