我使用本教程创建了一个AWS MSK Kafka集群
https://docs.aws.amazon.com/msk/latest/developerguide/msk-serverless-produce-consume.html
但是,我如何将本地的Laravel应用程序连接到应用程序1是生产者而应用程序2是消费者的集群?我偶然发现了这个包裹
https://github.com/mateusjunges/laravel-kafka
但它没有提到连接到AWS MSK集群。
niwlg2el1#
MSK Serverless仅提供IAM身份验证机制。AWS提供了authentication lib for clients,它将与基于Java的客户端一起工作,而Laravel是一个基于PHP的框架。您需要切换到已调配的MSK群集。切换后,您可以使用控制台或CLI或其他API访问MSK cluster's bootstrap information。目前,你有bootstrapping String,它只是一个Apache Kafka,所以创建属性并遵循Laravel文档或你提供的github集成项目。您需要记住的一件事是为运行客户端应用程序的计算机/安全组创建MSK安全组入站规则。请按照security guidance。
1条答案
按热度按时间niwlg2el1#
MSK Serverless仅提供IAM身份验证机制。
AWS提供了authentication lib for clients,它将与基于Java的客户端一起工作,而Laravel是一个基于PHP的框架。
您需要切换到已调配的MSK群集。
切换后,您可以使用控制台或CLI或其他API访问MSK cluster's bootstrap information。
目前,你有bootstrapping String,它只是一个Apache Kafka,所以创建属性并遵循Laravel文档或你提供的github集成项目。
您需要记住的一件事是为运行客户端应用程序的计算机/安全组创建MSK安全组入站规则。
请按照security guidance。