kafka分布式并行消费处理架构

Mysql

数据处理节点1

推送

消费

...

查询到匹配的配置信息，则将数据推送到配置的主题上

前端软件通过集成服务上报数据，集成服务将前端数据发往kafka

np_sys_topic_config

np_sys_topic_config表中配置的主题

消费的数据，根据项目编号查询

数据分发服务

默认数据处理节点

defaultParkIndefaultParkOutdefaultParkChargedefaultParkStay

kafka集群

未查询到配置信息，则将数据推送到该默认主题上

数据处理节点n