更新内容: 1.可以增加多个计算任务实例(*.dll) 2.增加IChannelMesaageHandler接口,主节点和计算节点可以复用。 3.修复SouceFunction多次启动线程的问题。 4.增加Kafka数据接入的接口,支持Kafka接入数据的实时计算。 注:请到开源网址下载。 系统框架: 系统测试: CPU:4核 I5-7400 2.7GHz,内存:16G,随机数据点时... CSharpFlink 分布式实时计算框架,增加 Kafka 数据接口和加载多个计算任务下载地址