有没有办法使Google Cloud Pub/Sub Schema Fields可选？
标题说明了一切。我正在努力弄清楚如何制作具有可选字段的Google Cloud Pub/Sub Schema。还是在AVRO模式中具有可选字段，基本上直接与具有模式的…
在Springboot应用程序中使用KAFKA的AVRO模式对象，然后将消息存储在数据库中时，我需要映射类吗？
我有一个Springboot应用程序，该应用程序将听一个Kafka主题，该主题传递了符合Avro模式的消息。 Springboot应用程序将负责从Kafka获取这些消息，并将…
使用Contruent .NET软件包生产带有架构的别名名称的数据时出现错误
我的AVRO模式为OrderID及其别名是“ emp_order_id”，“ emp_order_no” 字段中的 字段名称 {“ name”：“ orderid”，“ Aliases”：[“ emp_order_…
带有本地架构文件的kafka avro Deserializer
背景 ： 我使用SpringKafka实施了基于AVRO的消费者和生产商。其他重要组成部分：Kafka-Broker，Zookeeper和架构Registry在Docker容器中运行。这对我来…
当我们有一个带有空对象的数组时，无法序列化AVRO模式
我有对象列表，其中一个对象为null。当我尝试序列化以下数据时，我将获得 的 schema { "name": "myList", "type": [ "null", { "type": "array", "ite…
apache avro ipc服务器端async
我正在尝试使用AVRO IPC实现异步服务器应用程序。据我所研究，可以通过调用生成的回调协议类的方法来调用client async呼叫： 我生成的协议类： @org.a…
将AVDL文件转换为Apache的某些东西，可以解析Avro Python软件包
我想做的就是将.AVDL文件解析为Python。我想利用来自Python内部的信息。 根据文档，Apache的Python软件包不处理.AVDL文件。我需要使用他们的 avro-too…
如何使用AVRO模式注册表在Kafka发送字节阵列
我正在尝试使用Java Pojo和AVRO模式和架构注册表将字节与JSON对象一起发送。所以我的问题是，我的代码应该如何将“字节”类型数据发送给JSON？ 我的生…
为什么Gogen-Avro生成的容器无法处理可选字段？
我有一个消费者和制作人。以及以下架构： { "namespace" : "lets.see.how.it.works", "type" : "record", "name" : "DataItem", "fields" : [ { "name…
twint到kafka-＆gt;不要在我的话题中收到任何活动
我试图通过TWINT加载一些推文，并使用Confluent-Kafka [Avro]进入Kafka主题 制作人。我没有任何错误，但是我的话题不会从TWINT中获得任何活动。在调试…
生成C＃xa0;类时，Avrogen删除了逻辑类型的属性
我正在使用 apache.avro.tools 版本 1.11.0 从我的 avro 架构生成 C# 类型。 以下是架构的一部分： "fields": [ { "name": "ShipDate", "type": { "ty…
AVRO 使用构造函数序列化 ac# 类
我的目标是能够序列化AC＃类。 我目前正在尝试使用 microsoft.hadoop.avro 序列化，但我似乎无法使它起作用，因为我的应用程序抛出了异常'type'type'a…
SBT-AVRO没有生成Scala类，可能的设置问题
我正在尝试使用 sbt-avro 在Scala项目中以生成Avro的Scala类模式。 这是项目结构： multi-tenant/ build.sbt project/ plugins.sbt src/ main/ resour…
如何在 Flink Operator 中使用带有子级的 Avro 生成类作为 UNION
我正在尝试构建 Avro 生成记录的列表，同时使用 .map() 迭代从 Kafka 源提取的 Kafka 记录。 我遇到的问题是，我必须处理该 Kafka 主题上的多种类型的…
