本月看點(diǎn)速覽
產(chǎn)品動(dòng)態(tài)
Pulsar 2.3.1 發(fā)布
PIP-34 : Key_Shared Subscription
PIP-26 : Delayed Message Delivery
PIP-30 : Kerberos Authentication
Go Schema Support
社區(qū)動(dòng)態(tài)
DataPipeline Meetup (China)
Flink Forward San Francisco (Overseas)
Pulsar 2.3.1 Release
Apache Pulsar 在 4 月 12 日正式發(fā)布了 2.3.1 版本！2.3.1 版本修復(fù)和改進(jìn)了眾多用戶在使用 2.3.0 版本中反饋的問題。這些修復(fù)覆蓋了從消息存儲(chǔ)核心，多語(yǔ)言客戶端，到 Pulsar Functions 等多方面。
2.3.1 版本特性的詳細(xì)解讀，請(qǐng)參考 ApachePulsar 的公眾號(hào)文章Apache Pulsar 發(fā)布 2.3.1 版本。
Pulsar 2.4.0 預(yù)覽
Apache Pulsar 2.4.0 版本即將發(fā)布，整個(gè)四月，團(tuán)隊(duì)成員圍繞 2.4.0 版本中的各項(xiàng)工作在緊張有序地進(jìn)行著。以下是 2.4.0 版本幾個(gè)特性的提前預(yù)覽。
PIP-34: Key_Shared Subscription
Apache Pulsar 提供了消息隊(duì)列和流的統(tǒng)一消息模型。目前支持 Exclusive、Failover 和 Shared 三種訂閱方式。在 Exclusive 和 Failover 訂閱方式下，一個(gè)分區(qū)只能被一個(gè)消費(fèi)者消費(fèi)，但是能夠保證消息的順序消費(fèi)；在 Shared 訂閱方式下，一個(gè)分區(qū)可以被多個(gè)消費(fèi)者以亂序的方式消費(fèi)，應(yīng)用可以通過增加消費(fèi)者的數(shù)量提供消費(fèi)的吞吐。 PIP-34 引入了 Key_Shared 的訂閱方式，這個(gè)消費(fèi)方式可以保證消費(fèi)者對(duì)同一分區(qū)里面的消息，按照 Partition Key 或者 Ordering Key 進(jìn)行有序消費(fèi)，同時(shí)可以通過增加消費(fèi)者數(shù)量來提高消費(fèi)的吞吐，兼顧了 Exclusive/Failover 的有序性和 Shared 的擴(kuò)展性。Key_Shared 訂閱方式將在 2.4.0 版本中發(fā)布。
關(guān)于 Key_Shared 訂閱的設(shè)計(jì)，請(qǐng)參考 PIP-34
(https://github.com/apache/pulsar/wiki/PIP-34%3A-Add-new-subscribe-type-Key_Failover)。
PIP-26: Delayed Message Delivery
Apache Pulsar 將在 2.4.0 版本中支持延時(shí)消息。用戶可以通過deliverAfter指定一條消息在多長(zhǎng)時(shí)間后進(jìn)行投遞，通過 delieverAt 指定一條消息在什么時(shí)候進(jìn)行投遞。延時(shí)消息只對(duì)共享訂閱的消費(fèi)者生效，對(duì)于獨(dú)占和災(zāi)備訂閱等具有消費(fèi)順序性的訂閱模式不生效。
關(guān)于 Delayed Message Delivery 的設(shè)計(jì)，請(qǐng)參考 PIP-26
(https://github.com/apache/pulsar/wiki/PIP-26%3A-Delayed-Message-Delivery)。
PIP-30: Kerberos Authentication
在 2.3.0 版本中，Pulsar 引入了對(duì) JWT (Json-Web-Token) 認(rèn)證的支持。在 2.4.0 版本中，Pulsar 正式支持使用 Kerberos 進(jìn)行安全認(rèn)證。所有關(guān)于 Kerberos 的特性開發(fā)都已經(jīng)合并到主干分支，將于 2.4.0 版本中發(fā)布。
關(guān)于 Kerberos 的支持，請(qǐng)參考 Kerberos authentication
(https://github.com/apache/pulsar/issues/3491)。
Go Schema
Schema 是 Apache Pulsar 作為一個(gè)云原生流數(shù)據(jù)平臺(tái)的靈魂組件。在 2.3.0 版本之前，只有 Java 客戶端實(shí)現(xiàn)了對(duì)所有 Schema 的支持。2.3.0 版本在 C++ 和 Python 客戶端實(shí)現(xiàn)了對(duì) Schema 的支持。2019 年 4 月，Pulsar 社區(qū)在 Go 客戶端實(shí)現(xiàn)了對(duì) Schema 的支持。Go 客戶端是繼 Java 客戶端之后第二個(gè)對(duì) Schema 進(jìn)行完整支持的客戶端。
關(guān)于 Go Schema 的支持，請(qǐng)參考[Go Schema for pulsar-client-go]
(https://github.com/apache/pulsar/pull/3904)。
DataPipeline Meetup
Apache Pulsar PMC 成員郭斯杰(StreamNative CEO) 受邀在 Datapipeline & RocketMQ Meetup 上分享了 Efficient Schemas in Event Streaming using Apache Pulsar，該分享受到社區(qū)的熱烈反響。
Flink Forward San Francisco 2019
Flink Forward 是 Ververica 組織的 Flink 年度技術(shù)大會(huì)，本屆在美國(guó)的大會(huì)于 2019 年 4 月 1 - 2 日在美國(guó)舊金山舉辦。大會(huì)的 keynotes 和技術(shù)分享涵蓋 Flink 用戶案例，F(xiàn)link 生態(tài)的增長(zhǎng)，流處理和實(shí)時(shí)分析等主題。演講嘉賓來自 Ververica，Alibaba，Comcast，The Trade Desk, Foyer, Lyft, Uber, Netflix 等企業(yè)的技術(shù)團(tuán)隊(duì)。來自 StreamNative 的郭斯杰分享了 Elastic Data Processing with Apache Pulsar and Apache Flink。
TALK
Elastic Data Processing with Apache Pulsar and Apache Flink
Speaker：Sijie Guo (StreamNative) 活動(dòng)鏈接：Conference Program – Flink Forward San Francisco 2019
以上是本期全部?jī)?nèi)容，謝謝閱讀。
我們下期再見～
