Hi guys,
>From the flink doc
*By default, if a custom partitioner is not specified for the Flink Kafka
Producer, the producer will use a FlinkFixedPartitioner that maps each
Flink Kafka Producer parallel subtask to a single Kafka partition (i.e.,
all records received by a sink subtask will end up in the same Kafka
partition).*

Does this mean that if my downstream topic has 40 partitions , I will need
40 parallel subtasks ?

Thanks,
Vishwas

Reply via email to