kafka ktable使用自定义序列化程序在3ktable上连接ktable

rlcwz9us  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(234)

我希望为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的连接?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题