Pulsar Flinkconnector 2.7.0 正式发布,支持最新版 Pulsar 与 Flink

剪发的Tony 2020-12-29 14:52:30 ⋅ 103 阅读

Pulsar Flink 连接器 2.7.0 支持 Apache Pulsar 2.7.0 和 Apache Flink 1.12 中的功能,并且与 Flink连接器 和Flink 消息格式完全兼容。

新版本特性:

  • 高性能的有序消息队列;
  • 为 Pulsar sink 引入 exactly-once 的语义(基于 Pulsar transaction);
  • 引入 upsert-pulsar 连接器;
  • 支持在  FLIP-27 和 FLIP-95 中引入的新的源接口和Table API;
  • 支持SQL读写元数据(FLIP-107)等等。

全部评论: 0

    我有话说:

    Pulsar Manger 0.2.0 正式发布, Apache Pulsar 的管理端

    Pulsar Manger 是由 StreamNative 公司开源并捐献给 Apache 基金会的 Apache Pulsar 的管理端。它是基于 Web 的 GUI 管理工具,支持多种环境的动态

    Pulsar Go Client 0.4.0 发布

    Pulsar Client Go 是 Apache Pulsar 的 Go 语言客户端。近期,社区发布 Pulsar Client Go 0.4.0 版本。 新特性 支持

    Apache Pulsar Go Client 0.3.0 版本发布

    Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台。 Pulsar Go Client 是分布式消息流平台 Apache Pulsar 的 Go 语言

    Yahoo 开源的 Pulsar 能否超越 Kafka?

    来源:性能架构链接:https://mp.weixin.qq.com/s/s4k9nioEDd1m2g0quj9kqA   Pulsar 是类似于 Kafka 的一个消息中间件,是

    40亿条/秒!Flink流批一体在阿里双11首次落地的背后

    来源:王峰(莫问) Flink 中文社区原文:https://mp.weixin.qq.com/s/BTzulif0LPEbUiv2aikscA 导读:今年的双 11,实时计算处理的流量洪峰创纪录

    「轻阅读」基于 Flink SQL CDC的实时数据同步方案,附视频

    整理:陈政羽(Flink 社区志愿者)原文:https://mp.weixin.qq.com/s/QNJlacBUlkMT7ksKKSNa5Q Flink 1.11 引入了 Flink SQL

    前端框架 Angular 11.0.0 正式发布,不再支持 IE 9 、10

    前端框架 Angular 11.0.0 正式发布。 Angular 11.0.0 将 TypeScript 升级到 4.0, 对 TypeScript 3.9 不再支持。 放弃了对 IE 9 、10

    Angular 11.1.0 正式发布支持 TypeScript 4.1

    。 近日,Angular 11.1.0 正式发布...

    Apache Shiro 1.7.0 发布支持 HTTP 严格传输安全 HSTS

    Shiro 1.7.0 发布,此版本包括自 1.6.0 版本以来解决的 7 个问题,现在可以从 maven 中央仓库下载使用。 <dependency>   <

    Logstash 7.9.2 发布,开源服务端数据处理流程

    Logstash 是开源的服务器端数据处理管道,能够同时从多个来源采集数据,转换数据,然后将数据发送到你喜欢的“存储库”中。目前,Logstash 7.9.2正式发布,该版本更新内容如下

    phpPgAdmin 7.13.0 发布

    phpPgAdmin 7.13.0版本于今天发布。该版本涉及以下更新: 增加对Postgres 13的支持; 增加对Postgres 14的暂时适配; 升级Jquery库为jquery 3.4.1

    Bootstrap 4.6.0 发布,前端开发框架

    Bootstrap 4.6.0 发布了。 v4.6.0 大的变化是官方对开发环境进行了大的调整以匹配即将正式发布的 v5 版本。官方表示,目前 v4.x 版本的文档改为基于 Hugo

    支付组件IJPay2.6.0 版本发布新增 PayPal 支付

    IJPay 让支付触手可及,封装了微信支付、QQ支付支付支付、银联支付、京东支付、PayPal 支付等常用的支付方式以及各种常用的接口

    Elasticsearch 7.11.2 发布,提升缓存效率

    Elasticsearch 7.11.2 正式发布,此次更新内容如下: 增强 提高碎片级请求缓存效率 #69505 Bug 修复 聚合 修正用 doc_count 执行过滤器的过滤器

    Gradle 7.0 发布,自动化构建工

    Gradle 7.0 现已发布。Gradle 是一个基于 Apache Ant 和 Apache Maven 概念的项目自动化构建工具

    Gradle 5.0 RC2 发布支持 Java 11、Kotlin DSL 生产就绪

    Gradle 5.0 RC2 发布了,Gradle 是一个基于 Apache Ant 和 Apache Maven 概念的项目自动化构建工具,支持依赖管理和多项目,类似 Maven,但比之简单轻便。

    Apache Beam 2.25.0 发布,大数据流处理批处理编程范式

    Apache Beam 2.25.0 发布了。Beam 是一个用于定义和执行数据处理管道的统一编程模型,包括 ETL、批处理流处理。Beam 项目重点在于数据处理的编程范式和接口定义,并不涉及具体

    Apache Beam 2.28.0 发布,大数据流处理批处理编程范式

    Apache Beam 2.28.0发布,Beam 是一个用于定义和执行数据处理管道的统一编程模型,包括 ETL、批处理流处理。Beam 项目重点在于数据处理的编程范式和接口定义,并不涉及具体

    Flink + 强化学习搭建实时推荐系统

    如今的推荐系统,对于实时性的要求越来越高,实时推荐的流程大致可以概括为:推荐系统对于用户的请求产生推荐,用户对推荐结果作出反馈 (购买/点击/离开等等),推荐系统再根据用户反馈作出新的推荐。这个过程中有两个值得关注的地方: 这可被视为是一个推荐...