@Geoffrey Shelton Okot Thanks a lot. It worked. When i created topics using kafka-topics.sh, it throwed LEADER_NOT_AVAILABLE on giving producer command. So i tried with auto-created topics and it worked without any error. ... View more

@Geoffrey Shelton Okot Yes i have enabled ranger-kafka plugin. Have tried with this document also (https://community.hortonworks.com/articles/17059/apache-ranger-and-kafka-1.html ). Created 3 policies for broker, producer and consumer as mentioned in that document, but still getting below error message on running the following producer command(./bin/kafka-console-producer.sh --broker-list hadoop-kafka0:6667 --topic test_2). hadoop-kafka0 is the hostname of my broker. Tried by giving ip instead of hostname. That also thrown the same error. "[2019-04-23 10:50:26,907] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 15 : {test_2=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)" ... View more

@Geoffrey Shelton Okot Its not a kerberized cluster. Also could you please tell me if there is any way to enable and use ranger with kafka in a non-kerberized cluster. Screenshots of ranger policy: ... View more