我希望为3ktables执行ktablejoin,类似于这样的操作
var joinedStream =
person
.join(
address,
Person::getAddress,
valueJoiner,
Materialized.with(Serdes.Integer(), jsonSerde))
.leftJoin(addressType, this::getAddressType,valueJoiner);
当jsonserde使用customavroservde具体化主题时,最终连接失败,出现序列化异常。
在streamjoin中执行此操作时,我能够使用streamjoin.with有助于为内部流设置序列化程序的功能来执行此操作,但是找不到类似于ktables的任何内容。
我应该如何执行与ktables的连接?
暂无答案!
目前还没有任何答案,快来回答吧!