kubernetes - Azure Kubernetes 服务 -> Confluent 云连接问题
问题描述
我有一个在 Azure k8s 中运行的服务,并尝试使用来自 Confluent Cloud(Kafka SaaS 解决方案)的消息。
获取以下错误跟踪:
[main] INFO org.apache.kafka.common.security.authenticator.AbstractLogin -
Successfully logged in.
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.7.0
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 448719dc99a19793
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1630412312849
[main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-test-1, groupId=test] Subscribed to topic(s): pricing.cdc.selling-prices.segment
[main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-test-1, groupId=test] Connection to node -1 (52.151.125.243/52.151.125.243:9092) terminated during authentication.
相同的配置适用于本地 k8s 集群和配置的 Apache Kafka 防火墙规则。关于可能原因的任何想法?
解决方案
尝试新环境后立即检查密钥和密码是否正确。
检查是否启用了 SSL 协议。为此,请放置额外的财产
props.put("ssl.enabled.protocols", "TLSv1.2")
到您的代码或配置文件。
模式注册表呢?与模式注册表的连接是否有效?
推荐阅读
- reactjs - 在 useCallBack() 函数中使用 setInterval() 对 useRef() 进行反应,在 clearInterval() 时未清除
- xcode - 无法在 Xcode 10.1 中编译情节提要
- amp-html - Webp in amp 与 jpg 替代品用于不受支持的浏览器
- android - 如何实现与视频的共享元素过渡
- r - 合并仅包含一个数字的多个文件
- javascript - 在 ASP.Net MVC 中以输入类型时间设置当前时间
- python - 同时使用 Django REST 框架和 Web 套接字
- git - 树的信息如何存储在 git 索引文件中?
- c# - System.InvalidOperationException:“由于缺少功能而跳过了所有实例。” 错误来自数据集还是代码?
- node.js - TS:错误:找不到模块(修改 tsconfig 没有帮助)