问在Faust应用中检查kafka主题是否存在
EN

Stack Overflow用户

提问于 2021-09-03 09:48:40

回答 1查看 69关注 0票数 0

我是新来的浮士德。

手头的任务是确保存在一些Kafka主题。我的想法是检查app的活跃性检查中是否存在所有必需的主题。

我已经浏览了Faust文档，但没有找到这样做的方法。在Faust应用程序中可以做到这一点吗？

我们可以在Faust中使用原生Kafka列表主题(http://kafka.apache.org/21/javadoc/org/apache/kafka/clients/admin/AdminClient.html#listTopics--)吗？

发布于 2021-09-03 14:17:30

我们可以在Faust中使用原生Kafka列表主题吗

假设您已经在Faust运行的位置安装了Java，那么您肯定可以运行一个shell命令。

否则，您可以使用kafka-python或confluent-kafka-python AdminClient来检查主题是否存在

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/69042896

复制

相似问题

问在Faust应用中检查kafka主题是否存在EN