avro

1热度

1回答

我想了解更多关于我们用于我们的卡夫卡话题的avro架构，我对此相对较新。我想知道是否有办法在特定情况下演变架构。我们用一个新字段更新我们的模式不能为空或任何默认值，因为这些标识符都是这种类型。为此我们所做的工作是创建新的主题，但有没有更好的方法来演进现有的模式。谢谢。

5热度

2回答

如何使用apache avro SchemaBuilder更新现有的avro模式？

我正在测试加载和检索不同种类的avro模式的新模式注册表。在测试过程中，我需要创建一堆不同类型的avro模式。由于涉及很多排列，我决定以编程方式创建模式。我正在使用apache avro SchemaBuilder来这样做。我创建使用的Avro： Schema oldSchema = SchemaBuilder .record("abc") .aliases("reco

1热度

1回答

无法使用Confluent模式注册表和Spring云流反序列化Avro消息

我正在使用Spring Cloud Stream和Confluent Schema Registry来注册Avro模式。模式已成功注册。但是，当我的流监听器收到消息时，有效负载仍然是字节。这是我的属性。 spring.cloud.stream.schemaRegistryClient.endpoint=http://localhost:8081 spring.cloud.stream.bin

1热度

1回答

python fastavro错误地转换float

我无法理解我在使用fastavro（以及常规avro）转换在我的avro模式中定义为float的数字时遇到的问题。我确信它与我不明白的数据类型存储有关。简而言之，我将一条记录传递给fastavro.dump，然后将结果传递回fastavro.load，并且当值超过〜9位数时，转换到/ from不会返回相同的结果。 import fastavro from io import BytesIO

0热度

1回答

有没有在protobuf 3中实现map <string，map <string，list <string> >>的方法？

我试过这个，但有范围问题。 message DataCollectionMessage { message subData { message SubDataList { repeated string data = 1; } map<string, subData> parameters = 1; } m

1热度

1回答

如果字段顺序发生变化，Avro模式不兼容

场景 - 客户端使用Avro Reflect Datum Writer序列化POJO并将GenericRecord写入文件。通过反射所获得的模式是这样的（注顺序A，B，d，C） - { "namespace": "storage.management.example.schema", "type": "record", "doc": "Example schema for testing

0热度

1回答

无法打印Kafka Avro解码的消息

我有一个传统的基于C++的系统，它会吐出支持融合的Avro模式注册表格式的二进制编码的Avro数据。在我的Java应用程序中，我使用KafkaAvroDeserializer类成功反序列化消息，但无法打印出消息。 private void consumeAvroData(){ String group = "group1"; Properties props = new Pro

3热度

1回答

Apache AVRO与休息

我正在使用Apache AVRO评估我的Jersey休息服务。我使用Springboot和Jersey休息。目前我接受JSON作为输入whick jackson转换为Java pojos本身。我已经看过不同的地方，但找不到任何使用Apache AVRO泽西端点的例子。我发现这个Github链接https://github.com/FasterXML/jackson-dataformats-b

-3热度

1回答

scala - 以编程方式从纲要获取类（Apache avro）

我想用getter，setter和构造函数使用Avro纲要和mvn而不是sbt来生成一个scala类。感谢

2热度

1回答

Avro Schema Evolution：无法添加或删除字段

我目前正在尝试发展我的avro模式，根据文档应该没什么大不了的。但是，在添加或删除字段时，Avro无法反序列化字节。我用下面的模式： AvroSchemas.avsc： [ { "namespace": "stackoverflow.example.avro", "type": "record", "name": "Record_1_1", "f