Hi leiyanrui,
当 sink 的并发 小于 kafka partition 个数，同时 sink 并发只有一个时，FixPartitioner 会导致只会往一个分区发数据。 详见 FixPartitioner[1] 的实现，其中 `parallelInstanceId` 表示 subtask 的 编号，从0开始；`partitions.length` 表示该 topic 的分区个数， 最后返回该 subtask 应该往哪个分区发数据。 [1] https://github.com/apache/flink/blob/d00941c77170b233c9fe599c7fb0003778eb3299/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java#L75 Best, hailong At 2020-11-10 20:45:59, "leiyanrui" <[email protected]> wrote: > > > > >-- >Sent from: http://apache-flink.147419.n8.nabble.com/
