flink connector kafka_2.12 1.11.0.jar
flink是新一代的流式计算引擎,它需要从不同的第三方存储引擎读取数据,进行一定的处理,写出到不同的存储引擎,Connector就相当于是一个连接器,连接flink系统和外界存储系统。
用户评论
推荐下载
-
kafka_2.11_0.8.2.1.jar
kafka_2.11-0.8.2.1.jar
14 2019-05-28 -
kafka相关的jar包
kafka_2.10-0.10.0.0.jar,kafka_2.10-0.10.0.0-javadoc.jar,zookeeper-3.5.1.jar等72各jar包。最齐全的jar。你值得拥有
27 2019-05-01 -
Apache Jmeter Kafka Jar包
Jmeter的外部jar包放到在lib ext目录中启动Jmeter添加Java Request即可.
7 2023-01-31 -
Flink入门读取Kafka实时数据流实现WordCount
本文主要介绍Flink接收一个Kafka文本数据流,进行WordCount词频统计,然后输出到标准输出上。通过本文你可以了解如何编写和运行Flink程序。 代码拆解 首先要设置Flink的执行环境:
21 2021-01-15 -
Flink在CDH配置部署及读取kafka的实例验证
CDH目前不带flink组件,文档为Flink在CDH集群上的配置部署及读取kafka的实例验证;
67 2019-07-12 -
java实现flink订阅Kerberos认证的Kafka消息示例源码
java实现flink订阅Kerberos认证的Kafka消息源码
14 2021-04-16 -
Flink1.10.2基于CDH6.3.1安装包Scala2.12.rar
将2个jar包(一个为Flink运行在Yarn上,一个Flink使用自己的集群模式)上传到CDH的csd目录下,在将CDH需要的parcel文件放置在/usr/www/html(可以自己选择)目录下,
17 2021-03-26 -
flink依赖jar包解决NoClassDefFoundError comsunjersey
当flink on yarn模式运行时,发生如下异常信息,需要将压缩包中的4个依赖jar包放入flink安装路径下的lib目录下。 Exception in thread "main" java.la
37 2019-02-10 -
kylin engine flink3.1.1SNAPSHOT.jar
kylin 3.1.0源码中kylin-engine-flink编译,已修改hadoopClasspathEnv = "`hadoop classpath`",编译完成后,作为测试
7 2020-07-17 -
Hudi集成Flink的编译jar包
Hudi集成Flink的编译jar包在使用Flink将数据写入到Hudi时需要手动将此包导入到Maven中这样在代码中就能直接将数据写入到Hudi中了.Hadoop版本3.1.3Flink版本1.13
4 2023-01-19
暂无评论