我的目标群集已启用kerberos。从控制台,生产者连接正在工作。
./kafka-console-producer.sh --broker-list targetHost:port --topic test --producer.config /path/to/client.properties
我在我的bash\u配置文件中添加了下面的条目来传递haas.conf和krb5.conf
export KAFKA_OPTS="-Djava.security.auth.login.config=/path/to/jaas.conf -Djava.security.krb5.conf=/path/to/krb5.conf"
这是client.properties设置。
security.protocol=sasl\u纯文本
sasl.kerberos.service.name=Kafka
我正在使用 librdkafka
向Kafka发送信息并进行配置 security.protocol
以及 sasl.kerberos.service.name
为了Kafka configmap
对象。但这种联系没有发生。
如何集成 jars.conf
以及 krb5.conf
通过golang。
错误:
[thrd:sasl_plaintext://targethost:port/bootstrap]:萨斯勒_plaintext://targethost:port/bootstrap:未能初始化sasl身份验证:sasl握手失败(start(-1)):sasl(-1):常规故障:gssapi错误:杂项故障(请参阅文本(server(kafka/targethost)unknown while looking'targethost'(缓存结果,128秒内超时)
1条答案
按热度按时间agxfikkp1#
添加以下环境变量后,此问题已得到解决。
导出krb5_config=“/path/to/krb5.conf
另外添加了下面的kafka配置选项