Hi, I'm wondering how we can keep the kafka source key as flink partitioning key ? I can't find it in the doc.

You probably need a custom KafkaRecordDeserializationSchema where you extract the key of the message and use it later for .keyBy