看下kafka_client_jaas.conf 文件编写的 格式对不对 client{ ;}; 注意 总共两个分号 “;”
你好,我再kafka上设置好了sasl认证,然后再Java程序中的生产者和消费者设置了
System.setProperty("java.security.auth.login.config", "/Users/Sean/Documents/Gitrep/bigdata/kafka/src/main/resources/kafka_client_jaas.conf"); // 环境变量添加,需要输入配置文件的路径
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");,现在我生产和消费报这个错Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /home/hadoop/kafka_2.11-1.1.0/config/kafka_client_jaas.conf
大神,我的zookeeper集群设置了acl认证,kafka如何取连接这个acl认证的zookeeper集群呢?如何配置呢