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
10
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
9
2024-11-05
Apache Flink 1.13.6 二进制发行版(Scala 2.11)
Apache Flink 1.13.6 二进制发行版(Scala 2.11)
flink
16
2024-06-06
Flink Connector Kafka 1.13.2Scala 2.12
flink 的 Kafka 连接器里,flink-connector-kafka_2.12-1.13.2.jar这个版本算是比较稳定的老熟人了,Scala 2.12 环境下用它还挺顺手的,兼容性好,不容易踩坑。
Flink 1.13.2版本的配套连接器,API 变化不大,用起来也比较舒服,尤其是在你想用DataStream API去消费 Kafka 数据的时候,响应也快,代码也简单,实战里挺高频的。
之前试过其他版本,比如 2.11-1.13.6 也还行,不过2.12在 Scala 生态里更常见,配合 Flink 的 SQL 支持也蛮好用的,是写 SQL 查询 Kafka 表时,基本无缝衔接。
flink
0
2025-06-13
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
18
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
11
2024-05-21
Kafka 2.11-0.10.2.2 版本
Apache Kafka 2.11-0.10.2.2 版本软件包。
kafka
29
2024-05-12
探索Kafka 2.11版本
深入Kafka 2.11
Kafka 2.11版本带来了诸多改进与增强功能,使其成为构建可靠、高性能数据管道的理想选择。
关键特性:
增强消息可靠性: 优化了消息复制和持久化机制,确保数据安全性。
提升性能: 改进了数据压缩和消息传递效率,实现更优吞吐量。
扩展性增强: 支持更大规模的集群部署,满足海量数据处理需求。
流式处理优化: 完善了Kafka Streams API,简化流式应用开发。
安全性提升: 强化安全认证和授权机制,保护敏感数据。
适用场景:
构建实时数据管道
日志收集与分析
事件驱动架构
微服务通信
流式数据处理
kafka
17
2024-04-29
Kafka 2.11-0.10.0.0 资源获取
该页面提供 Kafka 2.11-0.10.0.0 版本的相关资源。
kafka
21
2024-05-16