一、前面和不需要认证的情况相同:
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";
Logo

技术共进,成长同行——讯飞AI开发者社区

更多推荐