fink
flink 的安装以及fink-cdc 基于多数据源导入的es 的简单使用
此文档是参照flink-cdc 文档( https://ververica.github.io/flink-cdc-connectors/master/content/快速上手/mysql-postgres-tutorial-zh.html) 案例 的最佳实践 1.下载flink release 最 ......
Fink
一。Flink和Spark一样,是一个大数据处理引擎。主要区别在于Flink做的是流处理,Spark做的是批处理。 二。Flink处理的是无界的和有界的数据流,做有状态的计算。Flink 设计旨在所有常见的集群环境中运行,以任意规模和内存级速度执行计算。 三。Flink 具有以下几个特点: 支持流处 ......
Kafka+Fink 实战+工具类
- LogServiceImpl ``` @Service @Slf4j public class LogServiceImpl implements LogService { private static final String TOPIC_NAME = "ods_link_visit_topi ......