开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink 消费topic list 是咋消费的 一个一个来吗

flink 消费topic list 是咋消费的 一个一个来吗

展开
收起
游客6vdkhpqtie2h2 2022-09-27 10:12:01 505 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    消费 Topic List 的规则:

    1、顺序消费:Flink 按照 Topic List 中消费者的顺序依次消费每个 Topic。这意味着如果您的 Topic List 包含多个根 Topic,则 Flink 将按照它们在 Topic List 中的顺序依次消费它们。

    2、并行消费:Flink 可以并行消费 Topic List,这意味着多个 Flink SQL 作业可以同时消费同一个 Topic List。这可以提高 Flink 的吞吐量和处理能力。

    3、时间戳消费:Flink 支持时间戳消费,这意味着 Flink SQL 作业可以根据消费者的时间戳来消费 Topic List。这可以确保 Flink SQL 作业按照正确的顺序消费 Topic List。

    4、事件驱动消费:Flink SQL 作业可以根据事件驱动来消费 Topic List。这意味着 Flink SQL 作业将等待特定的事件发生,然后才开始消费 Topic List。

    无论使用哪种规则,Flink SQL 都会在消费 Topic List 时执行相应的操作。

    2023-04-19 11:41:04
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载