Scala 2.11版本flink连接Kafka 1.13.6版本的jar包。
flink-connector-kafka_2.11-1.13.6.jar
相关推荐
flink-connector-hive 2.11-1.13.1.jar 文件
flink-connector-hive_2.11-1.13.1.jar 是 Apache Flink 用于连接 Hive 数据仓库的连接器,版本为 1.13.1,Scala 版本为 2.11。
Hive
3
2024-05-12
flink-sql-connector-hive-2.3.6_2.11-1.11.0.jar
文件 flink-sql-connector-hive-2.3.6_2.11-1.11.0.jar 是 Flink SQL 连接器与 Hive 的兼容版本,提供了对 Hive 数据源的读取和写入支持。
flink
0
2024-11-05
Apache Flink 1.13.6 二进制发行版(Scala 2.11)
Apache Flink 1.13.6 二进制发行版(Scala 2.11)
flink
2
2024-06-06
Apache Flink 1.13.6 CDC资源包详解
“flink-1.13.6_cdc”指的是Apache Flink的1.13.6版本,专为Change Data Capture (CDC)设计。Apache Flink是一款流行的开源流处理框架,支持实时数据流处理。CDC技术用于捕获数据库中的变更事件,并将其传输到其他系统进行处理或存储。该资源包包含了部署Flink CDC环境所需的所有组件和配置,如Flink运行时、相关连接器及配置文件。子文件包括Flink MySQL CDC连接器的JAR文件(版本2.0.1)和Flink SQL Elasticsearch 7连接器的JAR文件。此外,还包含了Flink 1.13.6的二进制发行版,用于在本地或集群上部署和运行Flink作业。整体而言,这个资源包支持用户实时捕获MySQL数据库变更事件,并通过Flink进行处理,最终将结果实时写入Elasticsearch,以提供实时的索引和搜索能力。
flink
0
2024-09-20
flink-connector-hive_2.12-1.12.0.jar 文件解析
flink-connector-hive_2.12-1.12.0.jar 文件是 Apache Flink 用于连接 Hive 数据源的连接器。
文件名的组成部分解析如下:* flink-connector-hive:表示这是一个 Flink 连接器,用于连接 Hive。* 2.12:表示该连接器兼容的 Scala 版本为 2.12。* 1.12.0:表示该连接器的版本号为 1.12.0。* .jar:表示这是一个 Java 归档文件(JAR 文件)。
flink
3
2024-05-21
Kafka 2.11-0.10.2.2 版本
Apache Kafka 2.11-0.10.2.2 版本软件包。
kafka
3
2024-05-12
Kafka 2.11-0.10.0.0 资源获取
该页面提供 Kafka 2.11-0.10.0.0 版本的相关资源。
kafka
2
2024-05-16
探索Kafka 2.11版本
深入Kafka 2.11
Kafka 2.11版本带来了诸多改进与增强功能,使其成为构建可靠、高性能数据管道的理想选择。
关键特性:
增强消息可靠性: 优化了消息复制和持久化机制,确保数据安全性。
提升性能: 改进了数据压缩和消息传递效率,实现更优吞吐量。
扩展性增强: 支持更大规模的集群部署,满足海量数据处理需求。
流式处理优化: 完善了Kafka Streams API,简化流式应用开发。
安全性提升: 强化安全认证和授权机制,保护敏感数据。
适用场景:
构建实时数据管道
日志收集与分析
事件驱动架构
微服务通信
流式数据处理
kafka
5
2024-04-29
Flink 1.14.4 安装包 (Scala 2.11)
Apache Flink 1.14.4 版本对应 Scala 2.11 的安装包。
flink
6
2024-05-12