数据传输方法和流式数据传输系统

摘要

本申请实施例提供了一种数据传输方法，所述方法包括：应用于流式数据传输系统中，所述流式传输系统包括由网关集群组成的数据传输层、由Kafka集群组成的数据缓存层、由Flink集群组成的数据分发层、及由多个终端组成的数据存储层，所述方法包括：所述网关集群接收待传输的数据流，并根据所述数据流的标识信息选择对应的逻辑管道将所述数据流写入至Kafka集群中与所述逻辑管道对应的主题中；所述Flink集群通过任务分发线程消费所述主题中的数据流，并将消费到的所述数据流分发至对应的终端中。本申请可以避免不同数据流的传输之间会相互影响。