spring boot 连接阿里巴巴 e-mapreduce kafka答案

【问题标题】：Spring boot connect to alibaba e-mapreduce kafkaspring boot 连接阿里巴巴 e-mapreduce kafka
【发布时间】：2020-06-14 11:06:48
【问题描述】：

我正在尝试将 spring boot kafka 应用程序连接到阿里巴巴云上的 kafka。
云在e-mapreduce service.
但是，我无法从启动连接，可能是因为我需要提供一些安全凭证？
我已经尝试将启动属性设置如下：

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的经验吗？

【问题讨论】：

标签： spring-boot apache-kafka spring-kafka alibaba-cloud

【解决方案1】：

相信Kafka Connect可以解决你在阿里云上连接spring boot kafka app到kafka的问题：

第 1 步：创建 Kafka 集群在 E-MapReduce 中创建一个源 Kafka 集群和一个目标 Kafka 集群。

第2步：创建一个主题用于存储要迁移的数据在源 Kafka 集群中创建一个名为 connect 的主题。

第 3 步：创建 Kafka Connect 连接器使用 Secure Shell (SSH) 登录到源 Kafka 集群的头节点。可选：自定义 Kafka Connect 配置。

第四步：查看Kafka Connect连接器和任务节点的状态查看Kafka Connect连接器和任务节点的状态，确保它们处于正常状态。

按照您的工作需要执行其他步骤。

详细说明请参见使用Kafka Connect迁移数据链接：https://www.alibabacloud.com/help/doc-detail/127685.htm

希望对你有帮助，

【讨论】：