我想在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
1条答案
按热度按时间ccgok5k51#
我能解决这个问题。kafka版本0.11[1]中增加了对sasl/scram的支持
我在上面的版本中也做了同样的操作,它工作正常。
谢谢。
[1] https://archive.apache.org/dist/kafka/0.10.2.0/release_notes.html