我在SCDF 2.10.3中使用拆分器和聚合器，我想在Redis中缓存消息。
下面是一个简单的示例流：http | splitter | aggregator | log
这个流在没有Redis的情况下工作正常。但是当我将Redis配置添加到聚合器时，我得到了一个序列化异常，因为对象没有实现Serializable。这是Redis默认序列化器的一个已知问题，但我找不到一种方法通过我传递给流的属性将GenericJackson2JsonRedisSerializer类设置为Redis序列化器，我宁愿不分叉聚合器应用！
有没有一种方法可以用属性来改变Redis的序列化器？
1条答案
按热度按时间txu3uszq1#
没有办法通过属性做到这一点。请随意提出GH问题，我们将从项目的Angular 考虑可以做什么以及如何做。
我目前看到的唯一解决方案是让自己的
RedisMessageStorebean注入相应的GenericJackson2JsonRedisSerializer。请记住，这个必须提供一个JacksonJsonUtils.messagingAwareMapper()，以进行适当的Message抽象（反）序列化。查看Spring Cloud DataFlow中的更多信息如何增强steam应用程序的classpath：https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#extend-classpath