设置kafka配置时出错

axzmvihb  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(430)

我想在Kafka配置sasl/scram。我在slide share中找到了这个资源[1](slide 52 create scram users),在创建用户时,出现以下错误。

Error while executing config command requirement failed: Invalid 
entity config: all configs to be added must be in the format
"key=val".
java.lang.IllegalArgumentException: requirement failed: Invalid entity config: all configs to be added must be in the format "key=val".
at scala.Predef$.require(Predef.scala:233)
at kafka.admin.ConfigCommand$.parseConfigsToBeAdded(ConfigCommand.scala:128)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:78)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:65)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)

这是我运行的配置。


# !/usr/bin/env bash

SCRAM_CONFIG='SCRAM-SHA-256=[iterations=8192,password=kafka123]'
SCRAM_CONFIG="$SCRAM_CONFIG,SCRAM-SHA-512=[password=kafka123]"

./kafka-configs.sh --alter --add-config "$SCRAM_CONFIG" --entity-type users --entity-name stocks_consumer --zookeeper localhost:2181 \

./kafka-configs.sh --alter --add-config "$SCRAM_CONFIG" --entity-type users --entity-name stocks_producer --zookeeper localhost:2181 \

./kafka-configs.sh --alter --add-config "$SCRAM_CONFIG" --entity-type users --entity-name admin --zookeeper localhost:2181 \

我找不到任何解决这个问题的办法,所以如果我能得到一个提示,让这个工作的感谢。
编辑:我正在使用Kafka版本2.10.0.10.1.0
谢谢
[1] https://www.slideshare.net/jeanpaulazar1/kafka-tutorial-kafka-security

ccgok5k5

ccgok5k51#

我能解决这个问题。kafka版本0.11[1]中增加了对sasl/scram的支持
我在上面的版本中也做了同样的操作,它工作正常。
谢谢。
[1] https://archive.apache.org/dist/kafka/0.10.2.0/release_notes.html

相关问题