kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ilter P <ilterpehli...@gmail.com>
Subject org.apache.kafka.common.errors.SecurityDisabledException: No Authorizer is configured on the broker.
Date Mon, 12 Nov 2018 20:02:18 GMT
Hi,

I am trying to create ACLs programatically during the connection and inside
the AuthenticationCallbackHandler.
I am using AdminClient API as:

****Initialize AdminClient***

properties = new HashMap<>();
//TODO: read Those from properties
properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
properties.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, "5000");
adminClient = AdminClient.create(properties);


***Actual call to create ACLs**

try{
  CreateAclsResult acls = adminClient.createAcls(aclList);
  acls.all().get();
}catch (Exception e){
  LOG.error("Error received while creating the ACLs",e);
  adminClient.close();
}


But I am getting following error in Kafka server:

java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.SecurityDisabledException: No
Authorizer is configured on the broker.

	at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)

	at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)

	at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)

	at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:262)

Anybody has any idea, I appreciate the help

Thanks

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message