kafka 在消费者中产生消息

Question

我有一个需要将消息传递到多层处理的应用程序。 我需要这样做，因为所有新消息都应该放入第一个通用主题中，以便可以对其进行处理以计算类型，然后将它们放入另一个主题中（以进行进一步处理），从现在开始相同key的消息，自动直接跳转到第二个主题。

我打算为每一层创建多个主题。消息首先进入第一层并得到处理，然后它们应该被发送到下一层（另一个主题），下一层可能会再次发生这种情况。 我想知道最好的做法是什么。可以在消费者中生成消息吗？或者还有其他更好的解决方案吗？

Answer 1

在消费者内部生产是完全可以接受的。 Faust 之类的 Python 库使这变得更加简单。