Spring boot连接阿里巴巴e-mapreduce kafka
我正在尝试将spring boot kafka应用程序连接到阿里云上的kafka。
云在e-mapreduce服务上。
但是，由于需要提供某些安全凭据，我无法从启动中连接？
我已经尝试按以下方式设置启动属性：
spring.kafka.properties.security.protocol=SSL
获取错误：到节点1的连接(/xx.xx.xx.xx:9092)在身份验证期间终止。这可能是由于以下任一原因造成的：（1）由于代理的凭据超过1.0.0而导致身份验证失败，(2)防火墙阻止Kafka TLS通信量（例如，它可能只允许HTTPS通信量），(3)短暂的网络问题。
spring.kafka.properties.security.protocol=SASL_SSL
由：java.lang.IllegalArgumentException引起的抛出：在JAAS配置中找不到“KafKaclient”条目。未设置系统属性“java.security.auth.login.config”
有人有在阿里云上连接Kafka的经验吗？
共有1个答案
我相信Kafka Connect可以解决您将spring boot Kafka应用连接到阿里云上的Kafka的问题：
步骤1：创建Kafka集群在e-MapReduce中创建源Kafka集群和目标Kafka集群。
步骤2：创建一个用于存储要迁移的数据的主题，在源Kafka集群中创建一个名为connect的主题。
希望这对你有帮助，
-
双非本科，参加了无数场面试，以下是最近面阿里的总结（来源于网络）： 阿里 面经1 简单介绍项目 知道哪些数据结构以及他们的特点 链表增删快，那如何提高其查询效率，有没有什么想法？ B+树了解吗？B+树如何范围查询？B+树退化的极端情况是什么？ 跳表了解吗？ 大顶堆、小顶堆了解吗？ 实现长地址请求到服务端，然后服务端重定向短地址给客户端，如何实现长短地址的互相映射？ 那我现在有10份数据，有1000
-
吹爆阿里，整个面试过程体验极佳！ 数据库怎么分类，描述一下你对这些数据库的理解 什么情况使用MySQL，什么情况使用Redis Redis有什么持久化策略 MySQL有哪2种引擎，说一下它们的区别 MySQL两个线程的update语句同时处理一条数据，会不会有阻塞 滥用事务，或者一个事务里有特别多sql的弊端 两条update语句处理一张表的不同的主键范围的记录，一个<10，一个>15，会不会遇到
-
#产品2023笔面经# 去年投简历直接挂 今年投终于收到了笔试 北森题库 40min 10言语理解 10资料分析 10图形推理 51性格测试 形式上和携程、shein的一致，只是性格测评不太一样，求一个面试机会吧
-
这次是被调岗加面一轮，由于自己的身体状况原因，中间歇了一段时间没有面试，发现距离上次面试已经过去大半个月了。 1.自我介绍 2.介绍一下上段实习主要做什么的，并且进行深挖 3.介绍一下上上段实习是干嘛的，通过什么模型之类的进行工作 4.你觉得你碰到最有挑战的工作是什么 5.为什么投了阿里 6.还投了什么其他公司，并追问为什么没去呢 我：因为没过面试 7.那你觉得面试为什么会没通过 8.读书和工作期
-
饿了么的数据研发岗位，整体面试体验很好！记录一下我的面（凉）经和反思吧～ 8-9 投递 8-13 行测+性格 8-21 笔试，15选择题，3个编程，我分别是100,90,6 8-25 一面 面试官先自我介绍，然后说大概全程30分钟，然后让我自我介绍。接着问更倾向于做算法还是做开发。有没有大数据，数据开发相关的经验，或者课。 接着问sql常用语句，优化方法。 数据结构相关，排序算法。 手撕代码：两个
-
双非本科，参加了无数场面试，以下是最近面阿里的总结： 阿里 面经1 简单介绍项目 知道哪些数据结构以及他们的特点 链表增删快，那如何提高其查询效率，有没有什么想法？ B+树了解吗？B+树如何范围查询？B+树退化的极端情况是什么？ 跳表了解吗？ 大顶堆、小顶堆了解吗？ 实现长地址请求到服务端，然后服务端重定向短地址给客户端，如何实现长短地址的互相映射？ 那我现在有10份数据，有1000个线程来争抢，