SpringBoot 对接华为大数据平台kerberos认证的Kafka数据
💡
原文中文,约4700字,阅读约需11分钟。
📝
内容提要
最近项目中使用华为大数据平台的Kafka数据源进行数据同步,采用kerberos认证。通过修改pom.xml依赖和配置文件,成功接入数据。配置kerberos认证文件,并在启动脚本中指定环境变量后,运行jar包即可。对接华为大数据平台的Kafka很简单,但网上教程较少。
🎯
关键要点
- 项目中使用华为大数据平台的Kafka数据源进行数据同步,采用kerberos认证。
- 修改pom.xml依赖,将Apache kafka-client包替换为华为自带的。
- 配置华为Maven镜像以获取相关依赖包。
- 在配置文件中新增huawei.mrs.kafka配置,而非使用spring.kafka相关配置。
- 新建HuaWeiMrsKafkaConfiguration类,配置Kafka相关信息。
- 创建KafkaConsumer类以消费Kafka数据。
- 配置kerberos认证文件,确保项目能正确读取相关配置。
- 将krb5.conf和user.keytab文件放置在与jar包相同的目录。
- 运行jar包时指定krb5.conf和jaas.conf环境变量。
- 对接华为大数据平台的Kafka过程简单,但网上教程较少。
🏷️
标签
➡️