kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mickael Maison (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-6107) SCRAM user add fails if Kafka has never been started
Date Tue, 24 Oct 2017 10:11:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216651#comment-16216651
] 

Mickael Maison commented on KAFKA-6107:
---------------------------------------

You also get a similar stack trace when setting up quotas with only zookeeper running. The
quotas are created correctly though

> SCRAM user add fails if Kafka has never been started
> ----------------------------------------------------
>
>                 Key: KAFKA-6107
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6107
>             Project: Kafka
>          Issue Type: Bug
>          Components: tools, zkclient
>    Affects Versions: 0.11.0.0
>            Reporter: Dustin Cote
>            Priority: Minor
>
> When trying to add a SCRAM user in ZooKeeper without having ever starting Kafka, the
kafka-configs tool does not handle it well. This is a common use case because starting a new
cluster where you want SCRAM for inter broker communication would generally result in seeing
this problem. Today, the workaround is to start Kafka, add the user, then restart Kafka. Here's
how to reproduce:
> 1) Start ZooKeeper
> 2) Run 
> {code}
> bin/kafka-configs --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=broker_pwd],SCRAM-SHA-512=[password=broker_pwd]'
--entity-type users --entity-name broker
> {code}
> This will result in:
> {code}
> bin/kafka-configs --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=broker_pwd],SCRAM-SHA-512=[password=broker_pwd]'
--entity-type users --entity-name broker
> Error while executing config command org.apache.zookeeper.KeeperException$NoNodeException:
KeeperErrorCode = NoNode for /config/changes/config_change_
> org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException:
KeeperErrorCode = NoNode for /config/changes/config_change_
> 	at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
> 	at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:1001)
> 	at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:528)
> 	at org.I0Itec.zkclient.ZkClient.createPersistentSequential(ZkClient.java:444)
> 	at kafka.utils.ZkPath.createPersistentSequential(ZkUtils.scala:1045)
> 	at kafka.utils.ZkUtils.createSequentialPersistentPath(ZkUtils.scala:527)
> 	at kafka.admin.AdminUtils$.kafka$admin$AdminUtils$$changeEntityConfig(AdminUtils.scala:600)
> 	at kafka.admin.AdminUtils$.changeUserOrUserClientIdConfig(AdminUtils.scala:551)
> 	at kafka.admin.AdminUtilities$class.changeConfigs(AdminUtils.scala:63)
> 	at kafka.admin.AdminUtils$.changeConfigs(AdminUtils.scala:72)
> 	at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:101)
> 	at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:68)
> 	at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
> Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode
for /config/changes/config_change_
> 	at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
> 	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:100)
> 	at org.I0Itec.zkclient.ZkClient$3.call(ZkClient.java:531)
> 	at org.I0Itec.zkclient.ZkClient$3.call(ZkClient.java:528)
> 	at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:991)
> 	... 11 more
> {code}
> The command doesn't appear to fail but it does throw an exception and return an error.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message