apache-kafka - 使用 kafka-avro-console-consumer 使用旧模式使用消息

Question

有没有办法使用 kafka-avro-console-consumer 来使用旧模式的消息？我设法使用我们的模式注册表来使用来自主题的消息，但它似乎总是使用最新的在此处输入代码

./kafka-avro-console-consumer --topic mytopic --partition 14 --offset 791197 --max-messages 1 --bootstrap-server mybootstrapserver.aws.confluent.cloud:9092 --property schema.registry.url=http://schemaregistry.mydomain --consumer.config consumer.properties

有没有办法指定特定版本的模式？

标签： apache-kafkakafka-consumer-apiconfluent-platform

Answer 1

在kafka-avro-console-consumer我找不到指定特定模式版本的选项的帮助功能中。据我了解，一个好的 Schema Registry 并不是要单独提供对所有版本的模式的访问，而是应用Schema Evolution的原则。

在您的情况下，使用新架构读取旧数据，架构必须是Backward Compatible。