在 Python 中加入 Kafka 流

Question

我需要在 Python 中使用 Kafka 流，并且正在分析可用的不同库。 这个问题提供了一些很好的答案，看起来Faust fork是Python中最完整的Kafka库。 但是，我需要加入不同的 Kafka 流，但我不确定如何实现这一点，或者是否支持它。

我搜索了 Faust 的文档，发现有一些连接的定义，但是如果我查看源代码，它们没有实现。所以看起来它们不受支持，但也许我错过了一些东西，或者有一个不同的库支持它。

我还发现了这个相关问题，但它是从 2017 年开始的，所以 Python 世界可能发生了很多变化。

Answer 1

我认为bytewax可能是你最好的选择。您可以阅读多个主题，并且在主分支中，您可以执行joins。这是一个 kafka 示例。