You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by steven chen <st...@163.com> on 2020/08/24 08:04:14 UTC

flink kafka 分区问题

大佬们，有个问题一直不理解
1.FlinkKafkaProducer 往 kafka 中写数据时 kafka 有10分区，现在使用 round-robin 的方式进行分区，每个 task 都会轮循的写下游的所有 partition
为什么10分区的产生的偏移量会出现偏差。
2.多流join 数据偏移，如何修复
3.flink sql 能否repartition