Apache Avro是一个主要用于Apache Hadoop的数据序列化框架。
经过多次尝试，我无法解码 fastavro 库在根据架构验证数据时抛出的错误。以下是我得到的结果 文件“fastavro\_validation.pyx”，l...
无法使用 JDBC kafka-sink-connector 将 kafka 主题数据写入 postgres 数据库
我有一个 kafka 主题，我们在其中生成 avro 记录，其模式如下所示。 { “类型”：“记录”， “名称”：“测试值”， “命名空间”：&
Ksqldb：使用基本身份验证连接到 Confluence Schema 注册表
我目前正在为 ksqlDB 构建一个用例原型，该用例应该从填充有 String 键和 Avro 值的 Kafka 主题中读取。 我正在使用以下 docker-compose.yml 来设置我的开发
如何覆盖 avro 命名空间和名称以反序列化到 KafkaAvroDeserializer 中的特定类
我正在尝试反序列化 Kafka 中使用 Avro 序列化的记录。不幸的是，生产者（不是我，并且长期以来一直在为其他消费者生产）已经设定了一个模式......
更改命名空间时，Confluence 架构上出现预期兼容性错误
有谁知道为什么在添加新版本的架构时，使用向后兼容性在 Avro 架构中进行名称空间更改不会触发融合架构注册表中的错误。 发生了什么事...
使用 org.apache.avro.util.RandomData() 从 avro 模式生成 JSON 示例消息不支持 UNION 类型
这是我的 avro 架构。 { "命名空间": "example.avro", “类型”：“记录”， “名称”：“用户”， “字段”：[ { ...
我使用gradle插件从avro模式（com.github.davidmc24.gradle.plugin.avro）生成类，是否可以为前@DefaultSchema（JavaBeanSchema.class）添加任何注释到类级别...
我想要一系列小型独立服务，它们要么使用 Kafka 主题并将数据输出到不同的系统，要么相反：从系统接收数据并生成
use.latest.version 配置不适用于 kafka 生产者和模式注册表
我在本地配置了一个kafka集群以及一个模式注册表实例，我对use.latest.version配置有点困惑。从我在文档中读到的内容来看，这
Avro Schema 反序列化索引越界异常错误 - 架构解析
我有2个应用程序，一个正在向主题生成数据，另一个应用程序从主题接收数据。写入器模式版本与读取器（消费者）模式不同。制作人有新剧本...
使用 to_avro 将 Spark 数据帧序列化到 Spark 中的 avro
我有一个具有以下架构的 Spark 数据框 结构类型( StructField(id,字符串类型,true), StructField（类型，StringType，true）， ） 我需要使用以下命令转换为 avro...
我希望能够使用类似于“hdfs -text *.avro”但在 Google 云存储中的内容将 avro 文件读取为 json。我将在 python 脚本中解析 json 我正在寻找 gsutil c...
我有来自 API 的 JSON 响应，我想根据现有的 Avro 架构进行验证（使用名称和类型进行严格验证）。 响应的类型为 {“姓名”：“亚历克斯”，“年龄”：23，“性别”：“M”，“
如何按照使用 Databricks 写入的顺序从 avro 文件中读取记录？
我有一个包含许多记录的avro 文件。我想保持数据写入文件的顺序。我没有可以排序的财产可以给我这个。 如何读取数据
我正在做Kafka的性能测试，需要测试不同的大型模式。目前，我正在从事基于 Avro 的负载测试。 通常，在使用 Kafka 时，您拥有数据并生成......
我有一个 Quarkus 项目和一个 kafka 生产者，其中有 特定的 AvroSerializer 成功写入主题，我可以看到消息正常 然后我将一个流附加到该主题...
有几篇关于如何根据文章 https://www.confluence.io/blog/multiple-event-types-in-the-same-kafka-topic/ 在同一 Kafka 主题上发出多个事件的文章。 我的问题是它如何...
是否有一个Python库可以将模式从pyspark数据帧转换为avro模式？
我正在构建一个应用程序，在其中使用 pyspark 查询 SQL Server 表。我的计划是将其推送到 kafka，它将被 Google Cloud Storage Sink Connector 使用并保存在 Go 中...
如何将 Apache Kafka Connect 与 Azure Schema 注册表集成？
我尝试使用 Confluence avro 转换器连接 Azure 架构注册表（向 avroConverter 提供架构注册表 url 和值转换器），但无法连接。 然后我在下面遇到了...
如何在 Kafka Connect 场景中禁用 Azure Schema 注册表上的架构自动注册？
有谁知道是否可以在 Kafka Connect 场景中设置源连接器，以便它不会自动在 Azure 架构注册表上注册架构？ 我问因为我是cur...