基于kafka的分布式消息数据总线

摘要

本发明基于kafka的分布式消息数据总线涉及信息数据领域，特别是一种适用于分布式数据库和分布式计算集群的分布式消息数据总线。包括kafka通用客户端接口和数据统一模型接口；所述kafka通用客户端接口用于统一不同版本的kafka producer和consumer客户端，屏蔽了外部系统对kafka各版本的使用限制，从而实现与不同版本kafka的producer、consumer客户端相连，保证两者接口结构一致；所述数据统一模型接口用于统一业务数据接口，与kafka数据解耦；根据接口结构，实现业务数据的统一模型组合/拆分逻辑。