实现用户密码登录的三种方式

 如果是写一个方法测试是否连接上，使用第一种方式；第二种方式会把文件缓存，必须重启程序才会生效。

1  直接输入用户密码

   每次可以根据输入的用户密码进行登录

  props.put("sasl.mechanism", "PLAIN");
  props.put("security.protocol", "SASL_PLAINTEXT");
  props.put("sasl.jaas.config","org.apache.kafka.common.security.plain.PlainLoginModule 
required username=\"producer\" password=\"prod-test\";");

2  加载配置文件

   修改文件后，要重启程序

 props.put("sasl.mechanism", "PLAIN");
 props.put("security.protocol", "SASL_PLAINTEXT");
 System.setProperty("java.security.auth.login.config", "‪E:\desktop\kafka_client_jaas.conf");

3 加入到程序启动参数中

java -jar -Djava.security.auth.login.config=D:/kafka_client_jaas.conf xxxx.jar //指定绝对路径