开启了Kerberos的Kafka客户端配置

Posted 光于前裕于后

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了开启了Kerberos的Kafka客户端配置相关的知识,希望对你有一定的参考价值。

如果不做任何配置将会报错:

WARN [Producer clientId=console-producer] Bootstrap broker xx:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

添加两个文件:

# client.properties
security.protocol=SASL_PLAINTEXT
sasl.kerberos.service.name=kafka
# jaas.conf
KafkaClient{
   
 com.sun.security.auth.module.Krb5LoginModule required
 useTicketCache=true

以上是关于开启了Kerberos的Kafka客户端配置的主要内容,如果未能解决你的问题,请参考以下文章

storm 访问 kerberos kafka

FlinkFlink跨集群访问开启Kerberos认证的Kafka

Kafka Kerberos客户端访问

Kafka 认证三:添加 Kerberos 认证详细流程

Kafka 认证三:添加 Kerberos 认证详细流程

Kafka 认证三:添加 Kerberos 认证详细流程