一种数据管理方法、中间件及数据管理系统

摘要

本申请提供了一种数据管理方法、中间件及数据管理系统，所述方法及中间件通过获得数据采集方的采集数据，生成所述采集数据的主题信息并封装所述采集数据及所述主题信息，以及发送封装有主题信息的采集数据至数据存储方(以使数据存储方根据所述采集数据的主题信息将所述采集数据存储至相应主题所对应的存储位置处)，实现了将数据采集方的采集数据写入至数据存储方，从而利用本申请方案，可通过中间件形式实现将Flume OG等数据采集方的采集数据写入至Kafka等数据存储方，解决了现有技术中早期Flume版本因没有Kafka插件，而导致的无法将收集到的日志写入Kafka的问题。