开发者社区 问答 正文

Flink流数据处理中消息传输层需要具备哪些理想功能呢?

Flink流数据处理中消息传输层需要具备哪些理想功能呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-08 22:05:11 594 分享 版权
1 条回答
写回答
取消 提交回答
  • (1)兼备高性能和持久性:

    具有持久性的好处之一是消息可以重播,这个功能使得FLink处理器对时间流的某一部分可以进行重播和在计算。

    (2)将生产者和消费者解耦:

    从生产者到达消费者,到达的消息既可以立刻被使用,也可以稍后被使用。

    2021-12-08 22:45:01
    赞同 展开评论