I'm using Flink SQL and have several Kafka topics with different partition counts, ranging from 4 to 320 partitions. Is it possible to specify the level of parallelism as a HINT in queries or CREATE statements? If I don't define any, it defaults to parallelism.default. However, since the entire program is defined in a .sql file, I want to set different levels for each query.
I understand that the parallelism level of a Kafka source matches the number of partitions in the topic, although I haven’t found this explicitly mentioned in the documentation.
