如何使用 Java API 添加 SCRAM-SHA-512 Kafka配置？

Question

我想向我的kafka集群添加新用户，方法似乎是在zookeeper数据库中添加SCRAM-SHA-512/256配置，但我只知道如何使用命令行实用程序来完成，如下所示：

bin/kafka-configs.sh --zookeeper zookeeper_server_address --alter --add-config "SCRAM-SHA-512=[password=password]" --entity-type users --entity-name userName

有没有使用Kafka API for Java的替代方法？

Answer 1

我看到一个帖子说Kafka api没有这个功能，所以我做了一个定制。用于创建用户的sh脚本(create-user.sh):

#!/bin/bash

SERVER=$1
USER=$2
PASSWORD=$3

if [ "x$SERVER" = "x" ] || [ "x$USER" = "x" ] || [ "x$PASSWORD" = "x" ]; then
    echo "usage: $0 <server:port> <user> <password>"
    exit
fi
bin/kafka-configs.sh --zookeeper $SERVER --alter --add-config "SCRAM-SHA-512=[password=$PASSWORD]" --entity-type users --entity-name $USER

我从java程序中调用它:

ProcessBuilder pb = new ProcessBuilder("./create-user.sh", "zookeeper-server", "sampleUser", "password");
        pb.environment().put("PATH", "/home/myHome/Programs/java/jdk-13.0.2/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin");

Process p = pb.redirectErrorStream(true)
                .directory(new File("/home/myHome/Desktop/Kafka/kafka_2.12-2.4.1"))
                .start();

注意，我需要在PATH中指定一些目录，并将其作为环境变量传递给ProcessBuilder，因为如果不这样做，它将抛出错误，指出有命令找不到