KafkaConsumer API 0.9 是否有针对以下场景的解决方案？

Question

我对卡夫卡比较陌生。我已经开始使用 Kafka 0.9 开发应用程序，其中多个模块使用 Kafka 主题进行交互。

我特别卡在一个场景中，场景如下：

系统中有两个模块，即模块 1 和模块 2。这两个模块通过 Kafka 相互交互。模块 1 继续动态创建多个主题，并根据特定条件生成消息并推送到多个主题。现在模块 2 将在整个应用程序的生命周期中处于睡眠模式。只有当模块 2 有任何请求来消费来自特定主题的数据时，模块 2 才会消费数据。消耗数据后，模块 2 将再次进入睡眠模式。

我检查了许多门户网站，但找不到合乎逻辑的解决方案。

如何在 Kafka 0.9 中实现这个场景。 Java 中的小示例代码 sn-p 会有所帮助。

Answer 1

这是所有（消息）队列的行为方式。 但是，考虑到您如何描述您的问题，我实际上不确定您是否需要 Kafka。

您的这些模块到底是什么？应用模块？
您能否大致指定您期望的负载（例如 msgs/day）？