serialization - Apache Storm 1.1.0 中的自定义序列化程序

Question

我在 Storm 拓扑配置中使用自定义序列化程序，如下所示：

config.put(Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION, false);
config.registerSerialization(ObjectNode.class, ObjectNodeSerializer.class);

ObjectNodeSerializer.class 在螺栓准备期间很好地实例化，但在拓扑执行期间从不调用序列化和反序列化方法。

score 1 · Accepted Answer

默认情况下，Storm 在将任何元组传递给同一 Worker 中的螺栓时不会序列化它。如果您只有一个 Worker 进程（以本地集群模式运行？）并且想要测试序列化，请设置以下配置

topology.testing.always.try.serialize: true

1 回答 1