rt flink kafka java 源码

rt-flink-kafka-java 什么是Apache Flink? Apache Flink是一个框架和分布式处理引擎,用于对无边界和有边界的数据流进行有状态的计算。 Flink旨在运行在所有常见的集群环境中,以内存速度和任何规模执行计算。 数据可以作为无界流或有界流处理。 无限流: 无界流有一个起点,但没有定义的终点。 它们不会终止并在生成数据时提供数据。 有界流: 有界流具有定义的开始和结束。 可以通过在执行任何计算之前提取所有数据来处理有界流。 Apache Flink擅长处理无边界和有边界的数据集。 对时间和状态的精确控制使Flink的运行时能够在无限制的流上运行任何类