我是Kafka的新手。这是我关于Kafka模式不断变化的问题。我们如何在kafka消费端处理模式更改？如果我们在kafka发布端更改有效负载结构，如何确保kafka消费端没有中断？我想知道全行业的做法来处理这种情况。我不会为avro使用confluent的模式注册表。有没有其他经过考验的选择？
9ceoxa921#
schema registry是一个集中的模式管理和兼容性检查的解决方案，随着模式的发展，可以将模式注册表配置为kafka生产者和消费者
kafkaProducerProps.put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG,"http://localhost:8081");
kafkaConsumerProps.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, "true"); //Schema registry location. kafkaConsumerProps.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost:8081");
在8081上运行架构注册表请参阅下面的url以获取示例代码https://dzone.com/articles/kafka-avro-serialization-and-the-schema-registry
1条答案
按热度按时间9ceoxa921#
schema registry是一个集中的模式管理和兼容性检查的解决方案，随着模式的发展，可以将模式注册表配置为kafka生产者和消费者
在8081上运行架构注册表
请参阅下面的url以获取示例代码
https://dzone.com/articles/kafka-avro-serialization-and-the-schema-registry