如何使用 KafkaConsumer java SDK 使用来自 AWS MSK 集群的事件形式？

问题描述

我在 AWS MSK 中创建了一个集群并创建了一个主题。我可以在与集群相同的 VPC 中生成和使用来自 EC2 实例的事件。具体用例是我想使用 Java 来消费事件。 KafkaClient AWS SDK 没有任何用于事件消费的方法，所以我不能在这里使用它。我无法在创建 KafkaConsumer 时直接在 Properties() 中传递引导服务器，因为 IP 位于 VPC 内部。

我已经通过此 AWS guide 了解连接到 MSK 的方法，但不确定哪种方法适合这个确切的用例。我尝试了几种方法-

1. 将advertised.listerners 设置为实例的公共IP。 但是在创建 KafkaConsumer 后列出主题时仍然出现此错误- Connection to node -1 Could not be established. broker may not be available. (org.apache.kafka.clients.NetworkClient)

2. 在安全组入站规则中打开相关端口（在我的情况下为 PLAINTEXT 为 9092）。执行此操作后，我在尝试 telnet 到端口 9092 时仍然遇到 Connection refused 错误。

我的问题是上述任何一项都可以工作，我只是在这里缺少可以解决此问题的其他东西。还是以上方法都行不通？

我的最终目标是使用 Java 使用来自 MSK 集群的事件。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）