kafka流中两个ktable进行外键连接时生成的主题



当我们在kafka流中的两个ktable之间进行外键连接时,会生成哪些主题?它们都包含哪些数据?

你可以在Kafka Streams应用程序中观察到两种类型的中间主题:-repartition-changelog

-repartitiontopics需要在Kafka Streams应用程序调用命令更改key时使用。

-changelog主题表示变更日志状态(当您创建KTables时),其中流中的每个数据记录捕获表的状态更改。有关更多信息,请参见流和表的二元性。

最新更新