我试图做两件事。
1.使用python boto 3 API列出MSK主题,但我无法在boto 3.client(“Kafka”)中找到API
1.另外,我正在尝试使用相同的python boto 3 API重新启动broker。
- 我可以通过调用一个python模块来做到这一点,该模块包含调用上述API并成功重启代理的代码- VIA命令行
- 我无法通过lambda函数执行此操作,并将相同的python模块部署为代码,并且每次都会超时。
- 经过一些调查,我们了解到MSK API服务驻留在与lambda不同的VPC中,因此没有建立通信。
因此,尝试使用启用了execute-API的VPC端点来执行API网关路由,这次lambda绑定到API网关。
我们还是回到了开始的状态--电话超时了。
我能得到什么帮助-
- 如果有任何指向boto 3 API的列表主题方法的指针,请分享。
- 如果有一种方法可以从lambda函数调用reboot broker,如果共享的话,那将非常感谢。
- 关于上述情况的任何想法,或者如果您知道有关重新启动代理或列表主题或任何MSK API服务的可访问性的方式的任何限制,请让我知道,我将在这个方向暂停,直到有进一步的更新。因为,我想我已经花了几天时间在这上面了。
先谢谢你了。
1条答案
按热度按时间ut6juiuv1#
boto 3 API与列表主题方法
您将使用Python Kafka客户端,指向MSK引导服务器,然后构建
AdminClient
从lambda函数调用reboot broker的方法
您必须重新启动EC2服务器,而不是使用Kafka API