春云流多api版本

Question

问题：

一个春云流应用程序，

必须通过相同api的两个主要版本发送相同的数据。

spring:
    stream:
      bindings: 
        myApiV1-out-0:
          destination: api/v1/the/topic
        myApiV2-out-0:
          destination: api/v2/the/topic

问题：

对于这个问题，最优雅的解决方案是什么？

的想法/我想要的：

我的应用程序应该使用流桥发送到泛型绑定。

这个绑定应该消耗我的内部模型

myApiV1-out-0

• convert

• 将其转换为api模式V1，并通过将其发送到api模式V2，并通过myApiV2-out-0发送。

这是我自己必须实现的，还是有某种模式？

Answer 1

我认为在这个用例中使用Stream时，使用StreamBridge是正确的模式。下面是一个伪代码：

@Bean
public Consumer<String> receive() {

// convert to API mode V1.
streamBridge.send("myApiV1-out-0", conveted-data-v1);

// convert to API mode V2.
streamBridge.send("myApiV2-out-0", conveted-data-v2);

}