如何解决如何使用 KafkaConsumer java SDK 使用来自 AWS MSK 集群的事件形式？
我在 AWS MSK 中创建了一个集群并创建了一个主题。我可以在与集群相同的 VPC 中生成和使用来自 EC2 实例的事件。具体用例是我想使用 Java 来消费事件。 KafkaClient AWS SDK 没有任何用于事件消费的方法，所以我不能在这里使用它。我无法在创建 KafkaConsumer 时直接在 Properties() 中传递引导服务器，因为 IP 位于 VPC 内部。
我已经通过此 AWS guide 了解连接到 MSK 的方法，但不确定哪种方法适合这个确切的用例。我尝试了几种方法-
-
将advertised.listerners 设置为实例的公共IP。 但是在创建 KafkaConsumer 后列出主题时仍然出现此错误-
Connection to node -1 Could not be established. broker may not be available. (org.apache.kafka.clients.NetworkClient) -
在安全组入站规则中打开相关端口（在我的情况下为 PLAINTEXT 为 9092）。执行此操作后，我在尝试 telnet 到端口 9092 时仍然遇到
Connection refused错误。
我的问题是上述任何一项都可以工作，我只是在这里缺少可以解决此问题的其他东西。还是以上方法都行不通？
我的最终目标是使用 Java 使用来自 MSK 集群的事件。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
