flink-kafka-hbase 功能：实现kafka消息实时落地hbase，支持csv/json字符串两种格式的消息，支持自定义组合rowkey,列簇和列名，支持按照kafka消息流中不同字段join不同的hbase表，并自定义写入列簇和列(join时需评估一下性能) 支持at least once语义 外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心 配置： { "indexColumnMapping": { --indexColumnMapping即CSV格式消息的key和value按照value里的分隔符拼接后再分割后下标及写入hbase列的对应关系 "0": "basic:time", --第0列始终是kafka消息的key，如果不需要可以不指定 "1": "basic:user_id",

StreamPark2.0.0编译版，直接解压安装启动

Flink相关论文

Flink jdbc connector 1.14.4

Flink1.14.4自定义flink-connector-jdbc连接SQLServer和SAP数据库

flink1.13.6安装包

《亿级在线实时动态规则运营系统（V2架构）》，2022年8月完结新课，基于flink1.14版本，提供课程配套的源码+文档+虚拟机下载！ 课程基于flink和groovy作为核心组件，实现可以任意在线动态制定规则的实时智能运营推送。 涉及的技术栈包括：flink streaming，flink sql，flink cdc，groovy ，redis ，elastic search， roaringbitmap 等； 项目的核心在于，在flink job运行期间，不需要停机即可以实时在线修改运算逻辑。

《基于Flink+FlinkCDC+FlinkSQL+Clickhouse构建实时数据仓库》——本课程为大数据实时数仓项目实战课程，以大数据实时数仓项目为主线，理论和实战相结合，全方位、全流程、无死角讲解数仓项目的数仓基础、项目规划、需求分析、架构设计与技术选型、大数据平台构建、项目业务介绍、数据采集、数仓建模理论、数仓设计规范、数仓搭建、实时分析以及数据大屏制作。学完本课程，零基础的学员能入行大数据仓库工程师，有开发基础的学员也能快速积累项目实战经验

分享视频教程——亿级在线实时动态规则运营系统（V2架构），2022年8月完结新课，视频+源码+文档课件+虚拟机下载

flink-hadoop-compatibility_2.12-1.7.1.jar javax.ws.rs-api-2.0.1.jar jersey-common-2.27.jar jersey-core-1.19.4.jar 解决 Exception in thread "main" java.lang.NoClassDefFoundError: com/sun/jersey/api/client/config/ClientConfig