classKafkaManager(val kafkaParams: Map[String, String]) KafkaManager(val kafkaParams: Map[String, Str 你的当前访问异常,请进行认证后继续阅读剩余内容。 提交