我知道，storm不能保证kafka主题的总排序保证，但是在许多文档中，storm保证消息的消耗/处理在分区级别保持顺序。我正在寻找一个示例storm拓扑，它使用/处理kafka主题的消息，在kafka分区级别维护消息的顺序。。不是全部订单！！只有分区级别的排序保证。请分享，如果你知道任何样本申请。谢谢！！
qmb5sa221#
你看过apache风暴的例子了吗？https://github.com/apache/storm/tree/master/external/storm-kafka您可能需要考虑标准示例，并根据您的需要对其进行缩放。另外，在为kafkaspuout定义模式时，您可能希望输出一些键作为元组的一部分，然后使用fieldg分组。
1条答案
按热度按时间qmb5sa221#
你看过apache风暴的例子了吗？https://github.com/apache/storm/tree/master/external/storm-kafka
您可能需要考虑标准示例，并根据您的需要对其进行缩放。另外，在为kafkaspuout定义模式时，您可能希望输出一些键作为元组的一部分，然后使用fieldg分组。