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