Kafka制作人使用默认分区

现在我的kafka生产者正在将所有消息下沉到kafka主题的单个分区，该分区实际上有超过1个分区。

如何创建将使用默认分区器并在主题的不同分区之间分发消息的生产者。

我的kafka制作人的代码片段：

Properties props = new Properties();
props.put(ProducerConfig.RETRIES_CONFIG, 0);
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrap.servers);
props.put(ProducerConfig.ACKS_CONFIG, "all");
我正在使用flink kafka生成器来收集关于kafka主题的消息。

speStream.addSink(

new FlinkKafkaProducer011(kafkaTopicName,
new KeyedSerializationSchemaWrapper<>(new SimpleStringSchema()), 
props, 
FlinkKafkaProducer011.Semantic.EXACTLY_ONCE)