Storm Spout 中的 MessageId 对象详解

Storm 的 Spout 中对每条发送出去的消息生成一个 MessageId 对象，内容为'C<RootId，StreamId，消息ID>'，其中 RootId 是拓扑中某个特定的 Tuple 的 MessageId，StreamId 是发射该 Tuple 的流的标识符，消息ID 是一个由 Spout 生成的唯一标识符，可以是任意类型的对象，例如字符串、整数等。消息ID 的生成方式可以由开发人员自定义，但需要保证唯一性。