加入两种不同KStreams

Question

值

所以，我有两个不同的KStream就像这样：

流1：（String键，Object值1）

流2：（String键，Object值2）

我想加入他们，这样我就会看到一个类似于（Object value1，Object value2）的流。

干净的方法是什么？

Answer 1

工作的一种方式是加入两个流，使得生成的流的值是包含两个原始值的容器类。然后，映射流以将值从容器中取出并将其中一个用作关键字。

代码：

KStream<String, Object> stream1; 
KStream<String, Object> stream2; 

KStream<Object, Object> joinedStream = stream1 
     .join(stream2, (value1, value2) -> new MyValueContainer(value1, value2)) 
     .map((key, container) -> new KeyValue<Object, Object>(container.getValue1(), container.getValue2()));