1回答
我正在尝试为下面的json创建avro模式 { "status": "status", "error": { "msg": "error messag
浏览 22提问于2019-09-17得票数 1
因此，模式生成是很好的。当我试图写avro文件时，我得到了空指针异常。，我想了解如何成为我的最终记录对象？对标头和数据的case类的更改，按照架构和记录进行。是否正确创建了下面的记录？更新2:
我认为诺尔斯家族的问题。预期这些记录几乎没有空的属性。由于我更改
浏览 5提问于2019-03-01得票数 0
我正在研究Avro作为序列化格式在Java应用程序中发布事件。
我想要做的是将一些Avro字节转换成一个特定Java类的实例，这个实例是我使用Avro插件生成的，反之亦然。我希望这样做，因为它允许使用我的代码的开发人员订阅特定事件，并接收表示该特定事件的特定生成类的实例(可能会将其从对象中转换为事件类，但不必触摸任何Avro特定代码)。我想我想在这两种解决方案之间找到一些东西，得到
浏览 2提问于2016-12-08得票数 3
这些是我的avro配置："key.converter.schema.registry.url" : "http://myurl.com" ,key.converter.schemas.enable=false
浏览 4提问于2020-02-19得票数 1
我正在尝试学习avro，并且在模式中有一个问题。有人说 "name": "userid", "type" : "string", }哪一个是对的？还是说它们是一样的？
谢谢!
浏览 3提问于2021-03-09得票数 3
该项目是用Scala编写的。以便在avro架构中定义的对象类型在项目的其余部分中是已知的。
IntelliJ能识别<e
浏览 0提问于2015-12-11得票数 6
Avro向后兼容性返回空记录。我发送一个由schema_ver1.avsc编码的记录和一个由schema_ver2.avsc编码的记录到kafka，然后，我通过ver2模式(Avro_json_schema_ver2)查询名为“avro_sink3解码”的火花放电流内存接收器。我希望有这样的记录。预期记录
浏览 4提问于2021-12-13得票数 0
我正在阅读关于Apache中的文档，但我不能理解它的用途，如何以及为什么或在哪些情况下我应该使用它们。使用模式或使用扩展Serializable接口的类有什么区别？<TransactionPojos> transactionPojos = readTransactionsAsPojo();
但是它没有解释readTransactionsAsPojo函数是如何构建的。我认为关于这一点有很多缺失的解释。
浏览 0提问于2020-06-17得票数 1
1回答
正在尝试读取avro文件。val df = spark.read.avro(file)尝试手动创建架构，但现在遇到以下问题(file)
com.databricks.spark.avro.SchemaConverters$IncompatibleSchemaException:无法将Avro架构转换为催化剂
浏览 0提问于2018-06-15得票数 1
1回答
我是avro的新手，我有一个要反序列化的avro文件。有些架构使用固定类型的数据来存储MAC地址。下面的架构是其中之一，并作为一种类型在不同的架构中使用。MAC地址的架构如下： "type": "fixed", &
浏览 1提问于2021-08-24得票数 1
回答已采纳
2回答
我有个关于嵌套阿夫罗记录的问题。实际上，我将Json文件转换为Avro文件。
Avro模式包含Json可能包含的所有可能字段(包括嵌套字段)，有时缺少一个或几个嵌套Json。当Jackson解析Json文件时，如果缺少嵌套Json，则相对jackson对象的引用为null。当我尝试创建Avro记录时，我得到了一个异常，因为嵌套的Avro<
浏览 7提问于2017-10-16得票数 0
我正在为我的项目编写Java生产者代码。我已经为所有需要传递的字段注册了Avro模式。我的注册模式-“姓名”：“索赔”，名称空间："com.schema.avro"，{
浏览 6提问于2020-08-24得票数 0
回答已采纳
1回答
我有一个带有第一个模式的avro文件，然后我更新了附加到同一文件的模式。所以现在我在一个文件中有两个模式。avro是如何处理这种情况的。我的上游系统可能会更新模式，但hdfs编写器可能在旧模式上。因此，在我更新编写器以处理较新的模式之前，hdfs avro文件将具有两个模式。
注意-我没有模式注册表，我每天创建一个avro文件。因此，如果在中午更新模式，我将拥有一个包含两个模式的avro文件。
浏览 0提问于2017-11-06得票数 0
：
我面临的一些挑战：
如何重命名字段？这需要在ConvertRecord处理器和模式生态系统之外的另一个处理器块中完成吗？这似乎是一个常见的场景，因
浏览 0提问于2019-01-26得票数 1
1回答
是否有通过bytesArray api读取AvroInputStream.binary并以某种方式指定编写版本的方法？val result = input.iterator.toSeq
换句话说，avro4s是否支持带有二进制记录的模式演化？
浏览 3提问于2017-03-23得票数 2
回答已采纳
1回答
我们尝试使用(org.apache.avro.generic.GenericRecordBuilder).生成GenericRecord。我们使用的是来自JsonObject的com.google.gson.JsonObject，但是我们被困住了如何转换为带有对象的JsonArray生成GenericRecord{8982", "type": "double"},
{"key":
浏览 0提问于2018-12-29得票数 2
回答已采纳
我试图建立一个阿夫罗生成记录的列表，同时在卡夫卡记录上迭代一个.map()，这是从卡夫卡源中提取出来的。模式： "com.zzz.yyy.Schema1",]试图找出我如何生成这些A
浏览 1提问于2022-04-01得票数 1
回答已采纳
我是否可以在此版本中创建嵌套avro数据格式的流，就像我在版本5中尝试的那样，它工作得很好，但在confluent-4.1.1中提到的嵌套avro模式中找不到有用的链接获取错误-
无法从架构注册表获取AVRO架构。找不到avro类型的</em
浏览 0提问于2018-10-16得票数 0
使用Avro Java API，我可以创建一个简单的记录模式，如下所示： .recordfields() .endRecord();
如何使用逻辑类型标记架构字段
浏览 0提问于2017-03-29得票数 13
回答已采纳
2回答
我试图在我们的软件中使用C++ avro库，但我遇到了一个严重的问题。我有一个"Value“类，它包装了一系列类型，我想使用avro来读/写它。这不仅包括简单类型，还包括类型的std::vectors、任意类等等。我的模式
浏览 11提问于2017-08-31得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
