org.apache.kafka.common.errors.SecurityDisabledException: No Authorizer is configured on the broker.

[ilter P]

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