Support Questions

Find answers, ask questions, and share your expertise

How can other users (apart from kafka user) create kafka topics with partitions and replication factor?

Explorer

Am assuming, users are not authorized to create topics directly (except kafka user) and topics can only be created while producing if there is non-existent topic provided user is authorized on ranger kafka policy. How can users (apart from kafka user) create topics with partitions and replication factor on a kerberized ranger enabled cluster? Am able to create topic while producing but below errors is shown up and am interested in creating topics with partition and replication

/usr/hdp/current/kafka-brokers/bin/kafka-console-producer.sh --broker-list hadoop1.test.local:6667 --topic mytest5 --security-protocol PLAINTEXTSASL

WARN Error while fetching metadata [{TopicMetadata for topic test5 ->
No partition metadata for topic test5 due to kafka.common.LeaderNotAvailableException}] for topic [test5]: class kafka.common.LeaderNotAvailableException  (kafka.producer.BrokerPartitionInfo)
3 REPLIES 3

Mentor

Please review the ranger Kafka plugin FAQ for current limitations. https://cwiki.apache.org/confluence/display/RANGER/Kafka+Plugin

Check the below link for creating topic with replication and partitions.

https://docs.hortonworks.com/HDPDocuments/HDP2/HDP-2.5.3/bk_security/content/secure-kafka-create-top...

Contributor
Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.