如何处理Kafka模式演变
如何处理Kafka模式演变
提问于 2020-04-26 08:18:21
我是kafka的新手，.Here是我对不断变化的kafka模式的疑问。
我们如何在kafka消费者端处理模式更改？
如果我们在kafka publisher端更改负载结构，我如何确保kafka消费者端不会中断？
我很有兴趣知道全行业的实践来处理这种情况。
我不会为avro使用Confluent的模式注册表。还有没有其他经过试验和测试的选项？
回答 1
Stack Overflow用户
发布于 2020-04-26 14:31:54
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
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/61434277
复制相关文章
相似问题
腾讯云开发者
