public void setMaximumMessagePerSecondPerCore(Integer maximumMessagePerSecondPerCore) {
        if (maximumMessagePerSecondPerCore == null || maximumMessagePerSecondPerCore <= 0) {
            log.error(
                    "Illegal flink.max.msg.rate.percore property, must be nonnull and positive, using default value: {}",
                    this.maximumMessagePerSecondPerCore);
        } else {
            this.maximumMessagePerSecondPerCore = maximumMessagePerSecondPerCore;
        }
    }
Initialize maximum message per second per core based on configuration

@param maximumMessagePerSecondPerCore The maximum messages per second per core
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java