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

如何从本地计算机和其他地区的EC2实例访问AWS MSK托管kafka队列

程化
2023-03-14

我正在AWS MSK上建立一个托管Kafka队列。当从本地计算机连接时,我似乎无法使安全性工作,也无法确定是否可以从一个区域使用安全组到另一个区域。

我已经在这里的主要文档中浏览了关于设置安全组的信息。但我似乎还是无法和经纪人联系上。我目前正在以以下方式从本地计算机中使用kafka脚本

bin/kafka-console-producer.sh --broker-list "my-broker-ip:9092" --topic "some-topic"

但不断得到结果

[2019-01-28 12:06:13,278] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

我已经将本地IP与我用VPC设置的安全组中的所有端口关联起来,并与kafka队列关联起来,但这似乎没有帮助。我也不明白我怎么能把我的盒子和Kafka队列联系起来,因为它们在不同的地区。这可能吗?

[2019-01-28 12:06:13,278]警告[Producer Clientid=Console-Producer]无法建立到节点-1的连接。代理可能不可用。(org.apache.kafka.clients.networkclient)

我已经将本地IP与我用VPC设置的安全组中的所有端口关联起来,并与kafka队列关联起来,但这似乎没有帮助。我也不明白我怎么能把我的盒子和Kafka队列联系起来,因为它们在不同的地区。这可能吗?

我希望能够连接我的本地生产者代码kafka队列并观察输出,而不是让它不断拒绝连接。

共有1个答案

曾成天
2023-03-14

据我所知,您必须从EC2上的客户端计算机访问MSK集群,而不能从本地计算机访问。

 类似资料:
  • 我需要通过本地机器上的应用程序代码访问驻留在GCP bigQuery中的数据集。 我已经在本地机器的下载文件夹中创建了一个项目、服务帐户和下载的json文件(包含密钥)。服务帐户已授权,且GCP中所有必需的API均已启用。问题在于设置GOOGLE_应用程序_凭据环境变量。无法从cloud shell和windows cmd设置它。带有密钥的json文件当前存储在下载文件夹中。 我是否需要将json

  • 问题内容: 我将开发环境设置为vmware中的Ubuntu服务器(安装了LAMP)。vmware在我的本地Windows 7计算机上运行。当我尝试通过HeidiSQL程序访问我的mysql服务器时,连接失败。我得到: 但是,我可以通过PhpMyAdmin访问数据库服务器。MySQL正在运行,我的连接凭据和端口均正确。 我读到您应该输入要连接的计算机的IP地址,作为my.cnf文件中的“绑定地址”。

  • 我目前尝试使用AWS lambda。lambda函数应该从S3 bucket加载zip文件(>10 MB)。S3桶位于中,而lambda函数位于中。 当我尝试保存lambda函数时,我得到: GetObject时出错。S3错误代码:AuthorizationHeaderMalformed。S3错误消息:授权头格式错误;“US-East-1”区域错误;应为“EU-Central-1” 这真的是问题所

  • 所以有几个网站会为你计算你的链接本地ipv6地址,就像这里的这个。 尽管如此,它并没有给出任何有用的关于这个地址是如何计算的,也没有输入参数是什么。那么,如果一个人知道自己的ipv4地址、子网掩码和网关地址,计算链路本地ipv6地址的过程(或算法)是什么?我正在使用SCTP套接字做一个项目,该项目使用ISATAP网络隧道和LL ipv6地址用于构建ISATAP地址。

  • 问题内容: 如何检测本地计算机所在的时区? 我尝试过,但是如果机器在德国,那不会给我例如时区“德国”。 有可能吗? 问题答案: 如果您的房东位于德国,则会返回您所在时区的ID(应该是柏林)。 在格式化程序中,您必须执行类似的操作才能在String中包含时区。

  • 我正在windows 8.1的笔记本电脑上使用Xampp localhost并试图通过我的手机访问它,我打开CMD并键入ipconfig和IPV4地址是192.168.1.3 我通过笔记本电脑打开它,它正常显示xampp文件夹,但当我将ip放入移动浏览器时,它什么也不给我(此网页不可用-ERR_CONNECTION_TIMED_OUT) 那么我怎样才能从我的android设备访问Xampp呢? 我