Как я могу добавить конфигурацию кафки Scram-Sha-512 с помощью Java API? ⇐ JAVA

[Anonymous]

Я хочу добавить новых пользователей в мой кластер Kafka, и способ сделать это, кажется, добавляется конфигурация Scram-Sha-512/256 в базу данных Zookeeper, но я знаю только, как это сделать с помощью утилиты командной строки, которая будет чем-то вроде этого:

Код: Выделить всё

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

Есть ли альтернатива, чтобы приблизиться к этому, используя API kafka для java?

Подробнее здесь: https://stackoverflow.com/questions/616 ... g-java-api