關於 Apache Pulsar
Apache Pulsar 是 Apache 軟件基金會頂級項目,是下一代雲原生分布式消息流平台,集消息、存儲、輕量化函數式計算為一體,採用計算與存儲分離架構設計,支持多租戶、持久化存儲、多機房跨區域數據複製,具有強一致性、高吞吐、低延時及高可擴展性等流數據存儲特性。GitHub 地址:http://github.com/apache/pulsar/
1 月 8-9 日,Flink Forward Asia 2021 將於線上舉辦。作為開源大數據領域的頂級盛會之一,Flink Forward 持續集結最佳行業實踐以及 Flink 最新技術動態,並積極擁抱生態夥伴,共建繁榮開源大數據生態。作為 Flink Forward Asia 2021 合作社區,Apache Pulsar 中文社區將支持本次大會的舉辦,同時 StreamNative 作為贊助商也設立了線上展位供大家更深入了解 Apache Pulsar,歡迎互動。
這種技術盛會上自然缺少不了 Apache Pulsar 的身影!來自 Apache Pulsar 的社區專家及多家一線互聯網科技公司的技術人員將會參與分享和討論。
•活動時間:1 月 8 - 9 日•活動形式:線上直播•大會官網:https://flink-forward.org.cn•線上觀看地址 (記得點擊預約直播哦) :https://developer.aliyun.com/special/ffa2021/live
議題詳情打造批流融合:Pulsar - Flink Connector 的設計、開發和使用
盛宇帆,StreamNative 工程師,Apache Pulsar/Flink Contributor,負責 Pulsar-Flink 等批流融合的開發工作。
內容摘要:對於 Flink 而言 Pulsar 是一個新鮮而又熟悉的老朋友,早在 19 年,我們就有計劃給 Flink 社區提交 Pulsar Connector 的代碼。隨着 Pulsar 社區的壯大,對於流批一體化的實踐,這一貢獻進度翻開了全新的篇章。本次將基於全新的 Flink Source 和 Sink API 重新設計並開發了 Pulsar Connector,並且已將 Sink API 合併到 Flink 的代碼倉庫進行維護。
本次演講,我們將介紹 Flink 1.14.0 新版本的一個特性 Pulsar-Flink Connector,以及當前的 Pulsar Connector 如何打通 Flink 和 Pulsar 之前的壁壘、如何使用全新的 Pulsar Connector 開發 Flink 應用來使用 Pulsar。
分享時間:1 月 9 日 10:40 - 11:20
如何參與
掃描下方海報二維碼或點擊閱讀原文立即預約直播!