Storm Config 提供了一些方便的方法来注册序列化器。（我说的是storm 0.9.2-incubating..）
registerSerialization(Class)
registerSerialization(Class, Class<? extends Serializer>)
registerSerialization(Map, Class, Class<? extends Serializer>)
如果我理解正确，第三个签名适用于您想要将新的序列化程序添加到给定配置的情况。
但是如何配置序列化程序实例？有装饰器，但你只能提供装饰器类，不能提供实例。
我正在寻找一种在我的 java 代码中将配置参数传递给序列化程序本身的方法。
任何帮助表示赞赏
谢谢，帕特里克