借助Flink與Pulsar,BIGO打造實(shí)時(shí)消息處理系統(tǒng)
BIGO 從 Kafka 轉(zhuǎn)向 Pulsar,并借助 Apache Pulsar 和 Flink 構(gòu)造實(shí)時(shí)消息流處理系統(tǒng)。本文整理自 BIGO Staff Engineer 陳航在 Flink Forward Asia 2020 分享的議題《借助 Flink 與 Pulsar,BIGO 打造實(shí)時(shí)消息處理系統(tǒng)》。主要內(nèi)容包括: 關(guān)于 BIGO BIGO 為什么會選擇 Apache Pulsar Apache Pulsar 在 BIGO 中的角色 BIGO 借助 Apache Pulsar 和 F