Мой целевой кластер включен Kerberos. Из консоли соединение с производителем работает.
./kafka-console-producer.sh --broker-list targetHost:port --topic test --producer.config /path/to/client.properties
Я добавил ниже запись в моем bash_profile, чтобы передать haas.conf и krb5.conf
export KAFKA_OPTS="-Djava.security.auth.login.config=/path/to/jaas.conf -Djava.security.krb5.conf=/path/to/krb5.conf"
Вот клиент. настройки свойств.
security.protocol = SASL_PLAINTEXT
sasl.kerberos.service.name = kafka
Для создания сообщения для Кафки и настроенные security.protocol и sasl.kerberos.service.name для кафки configmap объекта. Но соединение не происходит.
Как интегрировать jars.conf и krb5.conf через GoLang.
Ошибка:
[thrd: sasl_plaintext : // targetHost: порт / bootstrap]: sasl_plaintext: // targetHost: порт / bootstrap: не удалось инициализировать аутентификацию SASL: сбой рукопожатия SASL (запуск (-1)): SASL (-1): общий сбой: ошибка GSSAPI : Разный сбой (см. Текст (Сервер (kafka / targetHost) неизвестен при поиске «targetHost» (кэшированный результат, тайм-аут в 128 se c)