Как передать имя пользователя и пароль в KafkaConsumer?

Question

Не могу найти, как передать имя пользователя и пароль в KafkaConsumer. Я использую SASL PLAINTEXT для аутентификации клиента на сервере Kafka.

Я пытался найти эту информацию на https://kafka.apache.org/documentation/#consumerconfigs, но результат был отрицательным.

Я нашел пример, где автор использовалпараметры "имя пользователя" и "пароль". Я пытался сделать это:

props.put("bootstrap.servers", uri.getHost() + ":" + uri.getPort());
if (!groupidName.isBlank())
    props.put("group.id", groupidName);
props.put("enable.auto.commit", "false");
props.put("auto.offset.reset", groupidName.isBlank() ? "latest" : "earliest");
props.put("session.timeout.ms", "30000");
props.put("max.poll.records", "1");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
if (kafkaConnector.getConfig().getUserName() != null && kafkaConnector.getConfig().getPassword() != null)
{
    props.put("security.protocol","SASL_PLAINTEXT");
    props.put("sasl.mechanism","PLAIN");
    props.put("username",kafkaConnector.getConfig().getUserName());
    props.put("password",kafkaConnector.getConfig().getPassword());
}

, но я получил исключение "Не удалось создать потребитель kafka".

Если кто-то знает, как передать имя пользователя и пароль в конфигурацию потребителя, пожалуйста, помогите.