当前位置: 首页 > 面试题库 >

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

黄意智
2023-03-14
问题内容

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

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


问题答案:

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

是的,您可以将消息作为字节html" target="_blank">数组发送。如果查看Message类的构造函数,您将看到-

def this(bytes:Array [Byte])

现在,查看生产者send()API-

def send(producerData:ProducerData [K,V] *)

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

谢谢,Neha



 类似资料:
  • 我在服务器端对JSON进行了编码(使用ESAPI编码器),然后客户机检索bean的字段并进行进一步的处理。 在服务器端 编码的JSON字符串 \x7b\x22name\x22\x3a\x22sameer\x22,\x22company\x22\x3a\x22company\x22,\x22designation\x22\x3a\x22developer\x22\x7d 在客户端

  • 错误:错误:(49,9)找不到存储在数据集中的类型的编码器。导入spark.implicits支持基元类型(Int、String等)和产品类型(case类)。_在以后的版本中将增加对序列化其他类型的支持。.map(msg=>{

  • 本文向大家介绍如何使用nodejs对base64进行编解码?相关面试题,主要包含被问及如何使用nodejs对base64进行编解码?时的应答技巧和注意事项,需要的朋友参考一下 轮子, https://www.npmjs.com/package/js-base64

  • 我试图防止CRLF注入(在用户输入很少的url中),并试图对url中的用户输入进行编码。我知道我也可以使用输入验证,但如果我使用ESAPI编码器,它是否有相应的解码器?如果它有,那么它是什么?如果不是,那么可以做什么来执行相同的编码和解码?

  • 问题内容: 我将NodeJS与Express一起使用,当我在URL中使用外来字符时,它们会自动进行编码。 如何将其解码回原始字符串? 在调用NodeJS之前,我先转义字符。 所以字符串: 成为 现在,整个URL如下所示: 现在在我的NodeJS中,我得到了转义的字符串。 这是相关代码: 我已经尝试过和图书馆,但似乎没有适合我的情况。 问题答案: 更新16/03/18 并且已弃用。 用: 旧答案 给

  • 我正试图抓取一个网站,但它给了我一个错误。 我正在使用以下代码: 我得到了以下错误: 我能做些什么来解决这个问题?