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
