目前还不支持,可以去社区开个 issue,看能不能赶上1.12

Best,
Jark


On Thu, 29 Oct 2020 at 11:26, Dream-底限 <[email protected]> wrote:

> hi、
> 我看了一下官方提供的kafka sink,对于数据发送方式为两种:对于第二种情况,有办法保证对于指定主键的变化过程发送到同一个kafka
> partiiton吗,或者说社区对于原生hash(key)到kafka分区映射的方式有支持计划吗
>
>    - fixed:每个Flink分区最多只能有一个Kafka分区。
>    - round-robin:Flink分区循环分配给Kafka分区。
>

回复