Spring Cloud数据流:注册新的自定义kryo序列化程序

看见 KryoCodecAutoConfiguration .

PojoCodec 使用您自己的bean,或者简单地添加您的注册器(以及任何其他需要的注册器),SCSt将把它们连接到默认值中 波约科德克 ....

@Bean
@ConditionalOnMissingBean(PojoCodec.class)
public PojoCodec codec() {
    Map<String, KryoRegistrar> kryoRegistrarMap = applicationContext.getBeansOfType(KryoRegistrar.class);
    return new PojoCodec(new ArrayList<>(kryoRegistrarMap.values()), kryoCodecProperties.isReferences());
}

@Bean
@ConditionalOnMissingBean(KryoRegistrar.class)
public KryoRegistrar fileRegistrar() {
    return new FileKryoRegistrar();
}