一、前面和不需要認證的情況相同:
1、填寫Properties中的cluster name和版本,以及zk的ip和port
2、Advanced中填寫bootstrap servers
二、和不需要認證時不同的點:
1、Security的Type,不需要認證時選plaintext,需要認證時選擇對應的,比如SASL Plaintext
2、Advanced中SASL Mechanism需要填寫PLAIN,不需要認證時無需填寫
3、在JAAS Config欄填寫:
org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="your_password";