storm-kafka - 维护 Kafka 分区级别排序的风暴拓扑的示例应用程序或 Git 链接

Question

我知道，storm 不保证 kafka 主题的总排序保证，但在许多文档中看到，storm 保证在分区级别维护顺序的消耗/处理消息。

我正在寻找一个示例风暴拓扑，它使用/处理 kafka 主题的消息，在 kafka 分区级别维护消息的顺序。不是总订单！！仅分区级别排序保证。

如果您知道任何示例应用程序，请分享。多谢！！

Answer 1

你看过Apache Storm的例子吗？ https://github.com/apache/storm/tree/master/external/storm-kafka

您可能需要考虑标准示例并根据需要对其进行扩展。此外，在为 KafkaSpuout 定义模式时，您可能希望输出一些键作为元组的一部分，稍后使用 FieldG路由。