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

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

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 + 强化学习搭建实时推荐系统

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