KTable<key, Value1> table1 KTable<Key, Value2> table2
我想加入两个 KTables （无窗口）并将结果写入 <Key,value1,value2> 到输出主题。有谁能帮我提供一些如何进行这个操作的样品吗。
KTables
<Key,value1,value2>
tzxcd3kk1#
因为在ktable中，您总是只能有一个键和一个值，所以需要使用一些助手类将value1与value2连接起来。你可以用 Pair<> 从javatuples库：
Pair<>
KTable<Key, Pair<Value1,Value2>> table3 = table1.join(table2, (value1, value2) -> new Pair<Value1,Value2>(value1,value2));
要将其写入主题，需要为pair value实现自己的serde，然后：
table3.to(keySerde,pairSerde,"outputTopic")
1条答案
按热度按时间tzxcd3kk1#
因为在ktable中，您总是只能有一个键和一个值，所以需要使用一些助手类将value1与value2连接起来。你可以用
Pair<>从javatuples库：要将其写入主题，需要为pair value实现自己的serde，然后：