FlinkFlink kafka producer 分区策略 (flink写入数据不均匀 与 数据写入 分区无数据 )

Posted 2021-08-10 九师兄

文章目录

• 1.概述
• 2. FlinkFixedPartitioner
• 3.Tuple2FlinkPartitioner
• 4.FlinkKafkaDelegatePartitioner
• • 4.1 DefaultPartitioner
• 5.怎么使用默认的分区器
• 6. kafka分区器的配置
• 7.扩展

1.概述

思考这个问题，主要原因是，我们写了一个监控Kafka分区是否倾斜的程序，然后程序监控出来一个数据，写入倾斜的问题。

如下图