Ktable Ktable联接示例

Question

KTable<key, Value1> table1
KTable<Key, Value2> table2

我试图通过键连接两个KTables (无窗口)，并将结果作为<Key,value1,value2>写入输出主题。

有人能帮我给一些样本怎么做这个手术吗。

Answer 1

因为在KTable中，您总是可以只有一个键和一个值，所以您需要使用一些助手类来使用Value2连接您的Value1。您可以使用javatuples库中的Pair<>：

KTable<Key, Pair<Value1,Value2>> table3 = 
table1.join(table2, (value1, value2) -> new Pair<Value1,Value2>(value1,value2));

要将其写入主题，您需要为对值实现自己的serde，然后：

table3.to(keySerde,pairSerde,"outputTopic")