Flink開發中遇到的問題及解法

1. 當Source是Kafka的時候，如何設置Source Operator的併發度？網絡 若是沒有指定，Source Operator的個數與集羣中的TaskManager的個數相等。若是手動設置，建議使用的slot個數=Kafka Partition的個數／TaskManager的個數。此時，Slot的個數需大於等於2.由於其中有一個Source Operator。也不建議在一個Slot中啓

>>阅读原文<<