带有Kerberos认证的kafka

时间：2020-11-05 11:31:14 阅读：314 评论：0 收藏：0 [点我收藏+]

创建jass.conf，集群使用ambari，默认位置/usr/hdp/current/kafka-broker/config目录中。

文件内容为：
KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useTicketCache=true
renewTicket=true
serviceName="kafka";
};

Client {
com.sun.security.auth.module.Krb5LoginModule required
useTicketCache=true
renewTicket=true

useKeyTab=true
serviceName="kafka";
};

export KAFKA_OPTS="-Djava.security.auth.login.config=/path/jaas.conf"

创建客户端配置文件,client.properties

security.protocol=SASL_PLAINTEXTsasl.kerberos.service.name=kafkasasl.mechainsm=GSSAPI

生产者

./kafka-console-producer.sh --broker-list broker1:6667,broker2:6667 --topic test --producer.config /path/client.properties

消费者

./kafka-console-consumer.sh --bootstrap-server broker1:6667,broker2:6667 --topic sparktest --from-beginning --consumer.config /path/client.properties

作者：文竹小二
链接：https://www.jianshu.com/p/150ed14ec161
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

原文：https://www.cnblogs.com/wind-man/p/13930118.html

踩

(0)

评论一句话评论（0）

分享档案

更多>