2

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

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

如何集成到应用程序中？任何例子

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

msk 集群

4

2 回答 2

1

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

这取决于您如何设置 MSK？（VPC - 子网）检查您是否可以从本地访问或需要在 VPN 上访问。

另请参阅您的代理端点是如何配置和公开的 - 例如：

  • 明文（经纪人：9092）
  • TLS（代理：9094）

如果它是纯文本，它就像设置 bootstrap.servers 一样简单。

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

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

如果您仍有疑问，请告诉我。

于 2020-06-19T00:57:59.760 回答
0

如果您可以从kafka-console-*命令（或更简单的kafkacat）连接，那么您应该能够从任何其他应用程序进行连接。

我建议您在运行其他任何东西之前使用这些工具进行调试。

于 2020-06-18T21:38:54.687 回答