Support Questions
Find answers, ask questions, and share your expertise

Kafka Unauthorized Exception in Kerberos Enabled Cluster

Highlighted

Kafka Unauthorized Exception in Kerberos Enabled Cluster

New Contributor

Hello All,

I have enabled Kerberos on my HDP cluster. It has ranger plugin enabled as well. However upon start logs are showing below errors:

kafka.common.ClusterAuthorizationException: Request Request(1,*.*.*-*.*.*,Session(User:kafka,/*.*.*.*),null,1468508 405573,SASL_PLAINTEXT) is not authorized. at kafka.server.KafkaApis.authorizeClusterAction(KafkaApis.scala:913) at kafka.server.KafkaApis.handleUpdateMetadataRequest(KafkaApis.scala:158) at kafka.server.KafkaApis.handle(KafkaApis.scala:74) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)

Does anybody have an idea of why this is happening? Any help would be highly appreciated.

1 REPLY 1
Highlighted

Re: Kafka Unauthorized Exception in Kerberos Enabled Cluster

I hope you are starting your cluster with kafka user only?