Hi Harsha, It worked. I need to configure property super.users=User:kafka. (U should be capital in user, because of this issue, I have got the authentication error).
Regards, Bharat On Sat, Apr 16, 2016 at 9:21 AM, Harsha <m...@harsha.io> wrote: > Bharat, > Did you add super.users=user:kafka to your > server.properties. > -Harsha > > On Tue, Apr 12, 2016, at 05:07 PM, BigData dev wrote: > > Hi All, > > I am facing issue with kafka kerberoized cluster. > > > > After following the steps how to enables SASL on kafka by using below > > link. > > http://docs.confluent.io/2.0.0/kafka/sasl.html > > > > > > > > After this,when i start the kafka-server I am getting below error. > > [2016-04-12 16:59:26,201] ERROR [KafkaApi-1001] error when handling > > request > > > Name:LeaderAndIsrRequest;Version:0;Controller:1001;ControllerEpoch:3;CorrelationId:3;ClientId:1001;Leaders:BrokerEndPoint(1001, > > hostname.com,6667);PartitionState:(t1,0) -> > > > (LeaderAndIsrInfo:(Leader:1001,ISR:1001,LeaderEpoch:1,ControllerEpoch:3),ReplicationFactor:1),AllReplicas:1001),(ambari_kafka_service_check,0) > > -> > > > (LeaderAndIsrInfo:(Leader:1001,ISR:1001,LeaderEpoch:2,ControllerEpoch:3),ReplicationFactor:1),AllReplicas:1001) > > (kafka.server.KafkaApis) > > kafka.common.ClusterAuthorizationException: Request > > Request(0,9.30.150.20:6667-9.30.150.20:37550,Session(User:kafka,/ > 9.30.150.20),null,1460505566200,SASL_PLAINTEXT) > > is not authorized. > > at kafka.server.KafkaApis.authorizeClusterAction(KafkaApis.scala:910) > > at > > kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:113) > > at kafka.server.KafkaApis.handle(KafkaApis.scala:72) > > at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) > > at java.lang.Thread.run(Thread.java:745) > > > > > > Regards, > > Bharat >
