java - 如何从 spring boot kafka 项目连接到 aws MSK

Question

我正在尝试从 spring boot kafka 应用程序连接到 aws msk 集群。

我有 aws msk arn，引导服务器配置可用。

如何在应用中集成？ 任何例子

我可以从本地运行它吗，我的意思是从本地应用程序实例连接到 AWS MSK

msk cluster

Answer 1

连接到 AWS MSK 就像连接到任何 Kafka 集群一样。

这取决于您如何设置 MSK？ (专有网络 - 子网) 检查您是否可以从本地访问或需要使用 VPN。

另请查看您的代理端点是如何配置和公开的 - 例如:

• 明文(经纪人:9092)
• TLS(经纪人:9094)

如果是明文，设置bootstrap.servers一样简单。

否则，您需要添加下面提到的属性才能访问您的 MSK 集群。

security.protocol: SSL
ssl.truststore.location: jks
ssl.truststore.password: pwd

如果您还有问题，请告诉我。