flink寫入kafka默認只寫到一個partition

如題使用flink FlinkKafkaProducer0* 時，有一個最常用，也是官方例子的構造方法 有三個參數如下 /** * @param topicId * ID of the Kafka topic. * @param serializationSchema * User defined key-less serialization schema. * @pa

>>阅读原文<<