一学习就瞌睡: 配置多个kafka的时候，如果需要账号密码，无论是生产还是消费都可以单独配置。配置方法如下：例如在上文的consumerConfigsOutSchedule方法中添加配置（这里我为了方便直接用了字符串，自己配置可以像其他参数一样放在配置文件里）props.put(ConsumerConfig.SECURITY_PROVIDERS_CONFIG,"SASL_PLAINTEXT"); props.put(SaslConfigs.SASL_MECHANISM,"SCRAM-SHA-512"); props.put("sasl.jaas.config","org.apache.kafka.common.security.scram.ScramLoginModule required username=\"zjdx\" password=\"6ed7845e45765fb75b943253e944cd66\";"); 参数含义： SECURITY_PROVIDERS_CONFIG，安全验证是明文还是加密，"SASL_PLAINTEXT"是加密 SASL_MECHANISM，加密方式，"SCRAM-SHA-512"是MD5加密 "sasl.jaas.config"，信息配置，更改后面的username和password就行。这个配置可以看我之前发的一个帖，是类似的。等有时间再写个帖记录一下这个

一学习就瞌睡: 解决了，写评论底下，有需要的参考一下

一学习就瞌睡: 你的账号密码问题解决了么，我也遇到这个问题

m0_48470971: 怎么配置账号密码解决了么？

qq_41598508: 这个创建集群还需要去服务器上创建吗 还是直接web端创建