2

我们正在研究一种情况,即消息从 Kafka 队列中的源系统以无序的时间生成。

我们想对 Kafka 队列中的消息进行排序,或者想使用任何其他方法,以便 Kafka 消费者可以消费时间排序的消息,而不会影响太多的实时性。

只是为了提供信息,我们正在使用 Storm-Kafka 0.8 集成,因此无论如何都可以使用 Storm 处理它。

任何帮助或指导将不胜感激。

4

0 回答 0