Kafka 使用Python boto3 API的MSK列表主题和重启代理

j2qf4p5b  于 12个月前  发布在  Apache
关注(0)|答案(1)|浏览(210)

我试图做两件事。
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服务的可访问性的方式的任何限制,请让我知道,我将在这个方向暂停,直到有进一步的更新。因为,我想我已经花了几天时间在这上面了。

先谢谢你了。

ut6juiuv

ut6juiuv1#

boto 3 API与列表主题方法
您将使用Python Kafka客户端,指向MSK引导服务器,然后构建AdminClient
从lambda函数调用reboot broker的方法
您必须重新启动EC2服务器,而不是使用Kafka API

相关问题