Candice Chung的主页

答人回复 Candice Chung 在 kafka使用 SASL/PLAIN 认证 java客户端如何连接？中：

System.setProperty("java.security.auth.login.config", "/tmp/kafka_client_jaas.conf");

用这种方式，连接不同的kafka,账号和密码不一致怎么办的

6年前

隼回复 Candice Chung 在 kafka使用 SASL/PLAIN 认证 java客户端如何连接？中：

直接运行可以吗？还是要打成jar包上传才能使用？

7年前

Candice Chung 在 kafka使用 SASL/PLAIN 认证 java客户端如何连接？发表评论：

做了如下更改，可以消费到数据了

System.setProperty("java.security.auth.login.config", "/tmp/kafka_client_jaas.conf"); 
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");

7年前

发表了 kafka使用 SASL/PLAIN 认证 java客户端如何连接？

7年前

半兽人回复 Candice Chung 在 Kafka ACLs权限设置问题中：

给你个常用的例子吧

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --operation Write --operation Read --allow-principal User:* --allow-host 192.168.0.11 --add --topic test1

这样，就可以在11节点上对 topic test1 拥有读与写的权限

7年前

Candice Chung 回复半兽人在 Kafka ACLs权限设置问题中：

遇到了同样的问题啊。。。3台服务器，未设置ssl以及sasl 。在server.propertities中均配置了

#allow.everyone.if.no.acl.found=false
allow.everyone.if.no.acl.found=true
#zookeeper.set.acl=true
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
principal.builder.class=org.apache.kafka.common.security.auth.DefaultPrincipalBuilder

在其他服务器上，新增console-producer并发送消息，一切正常。acl的相关设置哪里出了问题么？

7年前