当前位置: 首页 > 知识库问答 >
问题:

从我的笔记本电脑连接到AWS MSKKafka:NoBrokersAvailable

仉英朗
2023-03-14

我无法从我的笔记本电脑连接到AWS MSK Kafka(与访问控制方法配置为无),错误是:NoBrokersAvailable

我在9092端口上使用明文conn:

from kafka import KafkaProducer 
kafka_brokers = [ "xxx.kafka.ap-east-1.amazonaws.com:9092","xxx.kafka.ap-east-1.amazonaws.com:9092","xxx.kafka.ap-east-1.amazonaws.com:9092" ]
producer = KafkaProducer(bootstrap_servers=kafka_brokers)

参考:AWS MSK-Plaintext broker端口9092,TLS 9094 https://docs.AWS.amazon.com/MSK/latest/developerguide/client-access.html

我尝试了三件事(但没有帮助):

a.在我的VPC默认安全组下,在9092+9094 source/dest 0.0.0.0/0上添加了入站+出站源/目标

b.按照以下说明在AWS客户端VPN上尝试运行:

    null

我看到其他一些人也在问类似的问题:如何将Python consumer连接到AWS MSK

有些人认为本地机器/笔记本电脑上的客户机连接到AWS MSK根本不受支持:我如何从本地机器和其他地区的EC2实例访问我的AWS MSK管理的kafka队列这是真的/官方的吗?

我在考虑创建EIP(弹性IP)https://repetitive.it/aws-msk-how-to-exposite-the-cluster-on-the-public-network/?lang=en,然后以某种方式与代理域名xxx.kafka.ap-east-1.amazonaws.com关联(但不确定如何)并配置入站出站规则。

但我一直找不到任何有用的东西。

我束手无策,这个问题已经耗了一整天了。非常感谢您的任何帮助。

谢谢

共有1个答案

燕实
2023-03-14

它将不可能直接连接到MSK经纪人从您的笔记本电脑。虽然MSK侦听器公开了一个公共DNS名称,但它实际上解析为MSK代理的一个私有IP。因此,由于您不在VPC内,您无法到达专用IP。

实现这一点的最便宜的选择是设置
AWS客户端VPNendpoint。

(编辑)观察到您已经尝试了客户端VPN,什么不起作用?我在用。

 类似资料:
  • 我想将IPython笔记本的宽度设置为2500px,并将其向左对齐。我该怎么做? 我使用此代码来应用我自己的CSS: 我的CSS的内容是: 如果我用这个CSS运行IPython脚本,那么我的笔记本网页将向左对齐,单元格的宽度为2000px,但是网页变成了大约1000px大小的水平滚动。所以我的细胞只有前半部分是可见的。 如果我设置在或在然后水平滚动消失,所以笔记本网页宽度将是2500px宽,我看到

  • 问题内容: 我正在开发一个用于监视笔记本电脑电源的应用程序。如果断电或恢复供电,它将通过电子邮件通知我。它还将对电子邮件进行应用程序监视和控制(基本上是通过电子邮件从我的办公室控制我的笔记本电脑)。我已经完成了电子邮件接口,但是我不知道如何从Java监视电源/电池供电。 如果有什么可以指点的,那将有很大的帮助。 提前致谢 .... 问题答案: 您可能已经解决了这个问题,但对于其他问题,您可以按照A

  • 我努力想喜欢IPython笔记本,但可能是因为我太习惯于用vi编写代码并在命令行执行,所以我发现它的一些默认设置很有挑战性。可以对以下内容做些什么(可能在某个配置文件中)? 我希望默认输出行号,而不必记住,也不必每次都设置别名。 我如何设置默认为"off",以阻止IPython污染我的命名空间与它的非百分比魔法和shell命令?我知道我可以使用选项和选项:是否有等效的选项? 让我抓狂的是,我从来都

  • 我想连接到raspberry pi和笔记本电脑。 这个想法是在不使用路由器或以太网电缆的情况下将其连接到笔记本电脑上,所以我想从笔记本电脑上创建一个接入点,并用无线加密狗将圆周率连接到笔记本电脑上。我们可以通过ssh交流。 我需要一个互联网连接来建立接入点吗? 连接的任何设备是否会获得IP地址?

  • 我有一台安装了Hadoop和Spark的机器。下面是我目前的环境。 Python3.6 /root/.ipython/profile_pyspark/startup/00-pyspark-setup.py /root/anaconda3/share/jupyter/kernels/pyspark/kernel.json kernel.json 所以,由于sc无法初始化,如果我想运行以下操作,它失败

  • 问题内容: 我正在尝试制作看起来不像tkinter应用程序的tkinter应用程序。我使用的是ttk笔记本,并且在选中选项卡时,这些选项在文本的周围都有一点点虚线。它看起来很糟糕,我找不到使用样式或配置删除它的方法。这是要说明的屏幕截图: 编辑代码(我认为这不会有很大帮助,因为我实际上只是在尝试删除默认样式的东西。): 这是笔记本的创建: 填写: 相关样式: 问题答案: 您可以通过更改选项卡小部件