python - 在 Faust 应用程序中检查 kafka 主题的存在

Question

我是浮士德的新手。

手头的任务是确保存在一些 Kafka 主题。想法是检查应用程序的活跃度检查中是否存在所有必需的主题。

我已经浏览了浮士德文档，但没有找到办法。甚至可以在浮士德应用程序中做到这一点吗？

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

标签： pythonapache-kafkafaust

Answer 1

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

假设你在 Faust 运行的地方安装了 Java，你当然可以运行 shell 命令。

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