Member since
09-21-2020
4
Posts
0
Kudos Received
0
Solutions
11-30-2020
07:42 PM
At last,I reinstall kafka and then it works.
... View more
11-20-2020
03:34 AM
Dear experts,I am running HDP 2.6.4 with enabled Kerberos and Ranger.Because the default zookeeper path of Kafka is under the root directory /, in order to facilitate the management of Kafka, the storage path of Kafka was changed to /kafka on the ambari page.
After change,the zookeeper.connect is:
hdp-node1:2181,hdp-node2:2181,hdp-node3:2181/kafka
Now I have a problem. When I create a topic with the following command, the following exception appears
sh kafka-topics.sh --create --zookeeper hdp-node1:2181,hdp-node2:2181,hdp-node3:2181/kafka --replication-factor 1 --partitions 3 --topic test_topic
And the follwing ERROR:
ERROR org.I0Itec.zkclient.exception.ZkException: org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:68)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:1000)
at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:527)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:293)
at kafka.utils.ZkPath$.createPersistent(ZkUtils.scala:965)
at kafka.utils.ZkUtils.createParentPath(ZkUtils.scala:437)
at kafka.utils.ZkUtils.updatePersistentPath(ZkUtils.scala:507)
at kafka.admin.AdminUtils$.writeEntityConfig(AdminUtils.scala:568)
at kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK(AdminUtils.scala:453)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:415)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:107)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:60)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics
at org.apache.zookeeper.KeeperException.create(KeeperException.java:113)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783)
at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:99)
at org.I0Itec.zkclient.ZkClient$3.call(ZkClient.java:530)
at org.I0Itec.zkclient.ZkClient$3.call(ZkClient.java:527)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:990)
... 11 more
Please help me to solve this ERROR,I should create topic in kafka normally.
... View more
Labels:
09-22-2020
07:03 PM
It works,thank you.
... View more
09-21-2020
07:20 PM
Dear experts,I am running HDP 2.6.4. Recently i have installed Ranger and integrated Hive. When i am trying to change Ambari Cluster Name and Ranger Hive Service Name, i am receiving the below errors in the hiveserver2.log. Could you please help ? 'cluster1' is the original cluster name,I want to change the cluster name to a different name. ERROR [Thread-13]: util.PolicyRefresher(PolicyRefresher.java:loadPolicyfromPolicyAdmin(285)) - PolicyRefresher(serviceName=cluster1_hive): failed to find service. Will clean up local cache of policies (-1)
org.apache.ranger.plugin.util.RangerServiceNotFoundException: cluster1_hive
... View more
Labels:
- Labels:
-
Apache Ambari
-
Apache Hive
-
Apache Ranger