Kafka 认证登录注意事项

最近，在写关于Kafka的消费端代码，发现若要消费，需要登录的时候，对对端Kafka服务进行认证，研究了一番，以下将代码放出来

参考了文章

Kafka配置安全认证_月下茶凉的博客-CSDN博客_kafka安全认证Kafka配置安全认证提示：本人提示：写完文章后，目录可以自动生成，如何生成可参考右边的帮助文档文章目录系列文章目录前言一、pandas是什么？二、使用步骤1.引入库2.读入数据总结前言提示：这里可以添加本文要记录的大概内容：例如：随着人工智能的不断发展，机器学习这门技术也越来越重要，很多人都开启了学习机器学习，本文就介绍了机器学习的基础内容。提示：以下是本篇文章正文内容，下面案例可供参考一、pandas是什么？示例：pan..https://blog.csdn.net/qq_42057890/article/details/117564848java 登录代码

// 注意 kafka_client_jaas.conf 是认证登录配置文件，里面记录使用了什么登录方式和登录账号密码
// 如果没有这个文件，程序运行的时候可能没有任何提示并且无法消费数据！
System.setProperty("java.security.auth.login.config","kafka_client_jaas.conf");        Properties props = new Properties();
props.put("bootstrap.servers", "xxx.xxx.xxx.xxx");
props.put("group.id", UUID.randomUUID().toString());
props.put("enable.auto.commit", "true");
props.put("auto.commit.interval.ms", "1000");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
props.put("auto.offset.reset","earliest");//加密传输协议
props.put("security.protocol","SASL_PLAINTEXT");
//加密方式
props.put("sasl.mechanism","SCRAM-SHA-256");//载入参数
KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<String,String>(props);

kafka_client_jaas.conf 文件配置

KafkaClient {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="XXXX"password="XXXX";
};

注意！

这里演示的是使用了

org.apache.kafka.common.security.plain.PlainLoginModule 模块

也有可能会使用其他模块，例如我项目需要用到

org.apache.kafka.common.security.scram.ScramLoginModule

如果使用了错误模块，运行程序的时候可能没有任何提示，并且不能消费数据！

Kafka 认证登录注意事项相关推荐

drcom宽带认证登录超时_开发SSO单点登录需要注意的问题
一.单点登录系统开发需要注意的问题 1.单点登录系统需要支持jsonp请求? 单点登录系统主要是向其他系统提供用户身份验证服务,因此需要提供对外接口,而外部系统通过接口访问时,必然涉及跨域问题,因此需 ...
spring security 自定义认证登录
spring security 自定义认证登录 1.概要 1.1.简介 spring security是一种基于 Spring AOP 和 Servlet 过滤器的安全框架,以此来管理权限认证等. 1 ...
SSH Secure Shell Client用public key认证登录
SSH Secure Shell Client用public key认证登录依据secureCRT的经验,走了一段弯路,今天,在这里把操作流程分享一把,可能本篇看似过与简单,但如果想用这一工具的伙伴 ...
linux用户双重认证登录,linux PAM 用户登录认证
PAM(Pluggable Authentication Modules )是由Sun提出的一种认证机制.它通过提供一些动态链接库和一套统一的API,将系统提供的服务和该服务的认证方式分开,使得系统 ...
Angularjs 通过asp.net web api认证登录
Angularjs 通过asp.net web api认证登录 Angularjs利用asp.net mvc提供的asp.net identity,membership实现居于数据库的用户名/密码的认 ...
【Kafka】Kafka认证与授权
防丢失:大家去看原文参考:https://www.cnblogs.com/rexcheny/articles/12884990.html 参考:https://www.orchome.com/553 ...
spring security——学习笔记（day05）-实现自定义 AuthenticationProvider身份认证-手机号码认证登录
目录 5.2 自定义 Provider 身份认证 5.2.1 编码思路和疑问 5.2.2 创建用户信息配置类 PhonePasswordAuthenticationToken 5.2.2 修改自定义的 ...
如何配置无线WiFi短信认证登录？
公共场所提供wifi上网服务,需要对用户进行实名认证,那如何配置无线WiFi短信认证登录? 本文将详细介绍无线wifi短信认证登录的流程及方法. 一. 短信验证码连接WiFi的功能怎么使用要实现访客 ...
mac下如何使用ssh-copy-id完成ssh的公钥认证登录
ssh-copy-id 是Linux 一个标准的命令行程序,用来时,实现公钥认证的ssh登陆. 在Linux下使用ssh-copy-id 可以轻松地实现本机到远程主机的公钥认证的ssh登录: ssh- ...

Kafka 认证登录注意事项

Kafka 认证登录注意事项相关推荐

最新文章

热门文章