我正在尝试从spring boot kafka应用程序连接到aws msk群集。我有aws msk arn，引导服务器配置可用。如何在应用程序中集成？有什么例子吗我可以从本地运行它，我的意思是从本地应用程序示例连接到aws-msk吗msk群集
ltskdhd11#
如果你能从 kafka-console-* 命令（或更简单的， kafkacat )然后您应该能够从任何其他应用程序进行连接。我建议您在运行其他工具之前使用这些工具进行调试。
kafka-console-*
kafkacat
ghg1uchk2#
连接到aws msk就像连接到任何kafka集群。这取决于你如何设置你的msk(vpc-子网）检查您是否可以从本地访问或需要使用vpn。另请参阅如何配置和公开代理终结点-例如：明文(broker:9092)tls公司(broker:9094)如果它是纯文本，那么设置bootstrap.servers就很简单了。否则，您需要添加下面提到的属性来访问您的msk集群。
security.protocol: SSL ssl.truststore.location: jks ssl.truststore.password: pwd
如果你还有问题，请告诉我。
2条答案
按热度按时间ltskdhd11#
如果你能从
kafka-console-*命令（或更简单的，kafkacat)然后您应该能够从任何其他应用程序进行连接。我建议您在运行其他工具之前使用这些工具进行调试。
ghg1uchk2#
连接到aws msk就像连接到任何kafka集群。
这取决于你如何设置你的msk(vpc-子网）检查您是否可以从本地访问或需要使用vpn。
另请参阅如何配置和公开代理终结点-例如：
明文(broker:9092)
tls公司(broker:9094)
如果它是纯文本，那么设置bootstrap.servers就很简单了。
否则，您需要添加下面提到的属性来访问您的msk集群。
如果你还有问题，请告诉我。