一种基于kafka的处理消息的方法

摘要

本发明公开一种基于kafka的处理消息的方法，模式信息作为消息头信息的一部分随消息一起发送，在消息传输时使用Apache Avro为消息传输格式。另一种方法，通过消息模式注册服务来实现消息模式变更通知，对于上游生产者应用生成的消息在发往kafka之前先到Schema Registrar注册并生成对应的模式编号，而随消息一起传递的是从模式注册服务获取到的该消息模式对应的编号，当下游消费者应用通过kafka获取到消息时，首先解析消息元数据信息，拿到消息模式编号，如果应用内存中有模式编号对应的模式信息，则根据模式信息解析消息，如果内存中没有，则应用发起请求根据模式编号从Schema Registrar中获取模式信息，然后根据模式信息解析消息，并缓存该模式信息。

主权项

一种基于kafka的处理消息的方法，其特征在于：模式信息作为消息头信息的一部分随消息一起发送，在消息传输时使用Apache Avro为消息传输格式。