开发者社区 问答 正文

麻烦问一下,flink kafka支持动态更改分区么,是用的assgin订阅么?#Flink

麻烦问一下,flink kafka支持动态更改分区么,是用的assgin订阅么?#Flink

展开
收起
黄一刀 2020-05-14 15:52:22 1665 分享 版权
1 条回答
写回答
取消 提交回答
  • 支持的,flink可以发现kafka分区的变化。只是flink source的并行度没法变。flink源码有个KafkaPartitionDiscover

    2020-05-14 15:53:17
    赞同 展开评论