Apache Storm - Scheme 和 MultiScheme 接口有什么区别？答案

【问题标题】：Apache Storm - What is the difference between the Scheme and the MultiScheme interface?Apache Storm - Scheme 和 MultiScheme 接口有什么区别？
【发布时间】：2016-12-19 19:40:38
【问题描述】：

我找不到任何关于 Apache Storm 的 Scheme 和 MultiScheme 接口的文档。实现在这里：

https://github.com/apache/storm/tree/master/storm-core/src/jvm/backtype/storm/spout

但我不明白什么时候应该使用Scheme，什么时候应该使用MultiScheme。我发现的大多数示例代码都使用了MultiScheme 的实现，许多还使用了神秘的SchemeAsMultiScheme 实现。谁能解释一下Scheme、MultiScheme 和SchemeAsMultiScheme 的实际用途？ RawMultiScheme 和 SchemeAsMultiScheme(new RawScheme()) 有区别吗？

【问题讨论】：

标签： java apache-storm

【解决方案1】：

Storm-Kafka GitHub 页面 (https://github.com/apache/storm/tree/master/external/storm-kafka) 上有不错的描述：

"默认的 RawMultiScheme 只接受 byte[] 并按原样返回一个带有 byte[] 的元组。outputField 的名称是“bytes”。有替代实现，如 SchemeAsMultiScheme 和 KeyValueSchemeAsMultiScheme 可以将 byte[] 转换为字符串。

SchemeAsMultiScheme 还有一个扩展，MessageMetadataSchemeAsMultiScheme，除了与消息关联的 Partition 和 offset 之外，它还有一个额外的反序列化方法接受消息 byte[]。”

【讨论】：