当我们在kafka流中的两个ktable之间进行外键连接时,会生成哪些主题?它们都包含哪些数据?
你可以在Kafka Streams应用程序中观察到两种类型的中间主题:-repartition
和-changelog
。
-repartition
topics需要在Kafka Streams应用程序调用命令更改key时使用。
-changelog
主题表示变更日志状态(当您创建KTables时),其中流中的每个数据记录捕获表的状态更改。有关更多信息,请参见流和表的二元性。