因此，在zookeper中创建了一个新的模式，如下所示现在，当我想在kafka流中消费消息时，我不知道我应该使用哪个serde -一个普通的StringSerde还是SpecificAvroSerde如何在不改变生产者中序列化器的情况下解决这个问题？
浏览 16提问于2019-08-20得票数 0
(我现在不想使用BJSON或其他二进制格式)
还回来。我将avro和json模式视为模式语言和生态系统，用于(反序列化)，但到目前为止我还没有找到任何工具来支付费
浏览 3提问于2016-06-02得票数 4
我试图在Ruby中完成avro序列化。我已经编写了JSON模式，但是我喜欢将序列化的数据以字节的形式写入Ruby中，而不是写入文件。"name": "User", [ {"na
浏览 5提问于2014-02-10得票数 5
回答已采纳
我有下面的属性设置在弹簧启动卡夫卡生产者application.yaml key.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer生产者属性： value.
浏览 2提问于2021-01-28得票数 0
我用avro-maven-plugin从Avro模式生成了Avro Java类。我将avro类序列化为一个字节数组，并将其写入kafka主题。然后我有一个kafka流，它试图操纵avro数据来做一些事情。在反序列化过程中，我从同一个类获得一个ClassCastExcetion。avro字节数组，然后需要手动反序列化avro的有效负载。我使用avro的解码器来反序列化如下：
Avro
浏览 1提问于2019-07-04得票数 4
回答已采纳
我正在使用Microsoft- avro -Core nuget包将C#对象序列化为Avro文件格式。我遇到的问题是，avro模式在json模式定义中包含一个名称空间属性，而序列化的avro文件的模式中没有包含该属性。 例如。"namespace": "topLevelRecord.record_data", ] "null"}
浏览 31提问于2021-10-06得票数 0
回答已采纳
可以通过Confluent将消息发布到使用KafkaAvroSerializer序列化的Kafka吗？我使用的是Flink 1.9.1，我看到一些开发是在flink-avro (1.11.0)的更新版本上进行的，但我坚持使用这个版本。我想使用新引入的KafkaSerializationSchema将消息序列化到融合的模式注册表和Kakfa。
在这里，我当前有一个将类类型T转换为avro的类，但我想使用合流序列化。static final Logger LOG = LoggerFactor
浏览 27提问于2020-05-10得票数 2
我使用json.net将pojo类序列化/反序列化为json，然后将其发送到rabbitmq.Now。我想使用apache avro format.How中的二进制数据执行同样的操作。可以在c#中序列化/反序列化对象吗？public class person public string FirstName { get; set; }
public string LastName {
浏览 4提问于2019-10-22得票数 1
1回答
我正在尝试建立一个kakfa管道，它将读取JSON输入数据到Kafka主题。到目前为止，GenericRecord用于解析模式。但是我最近才知道avro-tools可以用来读取模式和生成Java类，这些类可以用来创建生产者代码。由于我的模式经常更改，您能建议我哪一个更好吗？
浏览 1提问于2018-05-15得票数 0
1回答
我对Avro非常陌生，在网上浏览过一些例子。我所读过的大多数示例都是关于定义记录的，模式总是记录类型的。然而，现在我想做的是简单地序列化和反序列化一个字符串，尽管使用Avro。我不想定义任何周围的结构，如记录做什么。我不想要田园。简单地说，裸字符串序列化并反序列化为Avro。所以我的“顶级模式”应该类似于{"type": "string"}。
从
浏览 5提问于2022-06-14得票数 1
我使用Spark为我的数据生成预测，然后以Avro格式将它们存储到HDFS中：val output =dataPredictions.select("is", "probability", "prediction")我得到了以下例外：
com.databricks
浏览 2提问于2017-03-16得票数 1
1回答
给定一个AVRO模式，我创建一个符合此模式的JSON字符串。如何使用AVRO序列化JSON字符串以将其传递给卡夫卡生产者，后者需要AVRO编码的消息？
我发现的所有示例都没有JSON作为输入。顺便说一句，接收方随后将消息反序列化为POJO --我们正在不同的技术栈中工作。所以，基本上是JSON -> Kafka -> POJO。
浏览 1提问于2022-02-01得票数 0
1回答
我试图使用‘’将我的C#类序列化为' Avro‘，并将其发送到事件中心。然而，当我试图通过数据流分析读取数据时，它会在日志“无效的Avro格式，删除无效的记录”时出现此错误。//Create a new AvroSerializer instance and specify a custom serialization我已经创建了一个工作者角色，它可以使用这些事件并能够反序列化</em
浏览 3提问于2015-10-05得票数 0
回答已采纳
我注意到confluent有一个kafka序列化程序，它可以让我从kafka主题中序列化和反序列化case类，并且它会从注册表中拉出模式。 如果是这样，我使用avro4s会有什么好处？
浏览 15提问于2021-03-15得票数 0
1回答
) { return "";} private AvroData avroData;}
当我尝试将对象序列化为Json时，在尝试序列化Avro
浏览 0提问于2018-11-20得票数 1
1回答
我写了一个JMH基准测试来比较java 1.8中Avro (1.8.2)和Protobuf (3.5.0)的序列化性能。根据JMH的说法，Protobuf每秒可以序列化一些数据470万次，而Avro每秒只能序列化800k次。JMH对名为serialize的方法进行
浏览 31提问于2018-01-21得票数 3
3回答
我有Flume Avro接收器和读取接收器的SparkStreaming程序。CDH 5.1、Flume 1.5.0、Spark 1.0，使用Scala作为Spark上的程序语言有没有人有一个使用Scala的例子？
浏览 0提问于2014-08-25得票数 0
class(es)了data class Person(var firstName: String= "", var lastName: String = "") init { }但是，当我将
浏览 3提问于2021-01-26得票数 1
回答已采纳
我试图用Scala序列化/反序列化Avro map complexType。
有关于反序列化后如何处理import org.apache.avro.generic
浏览 0提问于2019-08-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
