问flink并行度和kafka分区在数据生产中有什么关系？

EN

每个FlinkKafkaConsumer分区只能被一个Kafka子任务消费，但一个FlinkKafkaConsumer可以消费一个或多个分区。假设一个主题有3个分区，最多可以分配3个FlinkKafkaConsumers的工作。

Flink任务槽最多可以包含作业中每个任务的一个实例。插槽的数量等于最大可用并行度。

类似地，Kafka分区的数量设置了最大可实现并行度的上限。

当并行度设置为1时，将只使用一个插槽，并且该插槽只能有一个FlinkKafkaConsumer (和一个FlinkKafkaProducer)。但是，一个使用者可以处理所有3个分区。如果并行度设置为3，那么3个使用者可能很忙，每个使用者在自己的插槽中处理一个分区。当并行度设置为4时，一个插槽将是空闲的。

在接收器中，默认情况下，FlinkKafkaProducer的每个实例将以循环方式写入每个分区。如果希望控制将每个记录写入哪个分区，则可以提供自定义FlinkKafkaPartitioner，也可以使用KafkaSerializationSchema并为每个ProducerRecord指定分区。