代码之家 › 专栏 › 技术社区 › tryingSpark

在schema registry中,消费者的schema可能不同于生产者的schema,这实际上意味着什么

confluent-schema-registry kafka-producer-api avro apache-kafka

tryingSpark · 技术社区 · 6 年前

在向Kafka生成AVRO数据时,AVRO序列化程序在字节数组中写入写入数据时使用的相同模式ID。

Kafka使用者根据接收到的字节数组中的模式ID从模式注册表获取模式。因此,在生产者和消费者中使用相同的模式ID,因此该模式。

one 说 消费者的模式可能与生产者的不同。

1 回复 | 直到 6 年前

OneCricketeer Gabriele Mariotti 6 年前

除非你让反序列化程序这么做。

您可以在消费代码中定义自己的兼容模式。因此,它 可能会有所不同

模式演化只发生在使用者(read)的反序列化过程中。如果使用者模式与生产者模式不同,则在反序列化期间会自动修改值或键,以尽可能符合使用者的读取模式。

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

2 年前

Sravan Kumar · Apache kafka模式注册表问题

3 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

3 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

3 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

3 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

3 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前