微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

SSL 错误无法以编程方式在 Confluent Cloud 中创建主题

如何解决SSL 错误无法以编程方式在 Confluent Cloud 中创建主题

我还没有看到可以自动实现主题创建的工作 python 客户端。我正在尝试 cofluent-kafka-python,但到目前为止还没有运气。

我可以使用 ccloud 连接到 Confluent 集群,我可以列出主题、创建主题等。但现在我试图将所有这些都放在 Python 代码中。

这不是初始化 AdminClient 的正确方法吗?

a = AdminClient({"bootstrap.servers": "-*.us-east-1.aws.confluent.cloud:9092"})>

到目前为止,我已经尝试安装 openssl & certifi & 然后将 ssl.ca.location 指向证书文件,但没有任何效果。我做错了什么?

我现在已经在我的 macbook 和全新的 linux 安装上完成了这件事,但两次都失败了。

%6|1613605742.589|FAIL|rdkafka#producer-2| [thrd:***-****.us-east-1.aws.confluent.cloud:9092/bootstrap]: ***-****.us-east-1.aws.confluent.cloud:9092/bootstrap: disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 204ms in state APIVERSION_QUERY)
%6|1613605742.992|FAIL|rdkafka#producer-2| [thrd:***-****.us-east-1.aws.confluent.cloud:9092/bootstrap]: ***-****.us-east-1.aws.confluent.cloud:9092/bootstrap: disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 205ms in state APIVERSION_QUERY,1 identical error(s) suppressed)
^CTraceback (most recent call last):
---------------

更新 1:如果我事先创建主题,使用 ccloud 或控制台然后使用它来生成事件,python 脚本工作正常。我只是取出 AdminClient 部分并且它可以工作。使用 AdminClient 创建主题失败并显示 SSL 错误

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。