当我们在kafka流中的两个KTable之间进行外键连接时,会生成哪些主题?它们包含哪些数据?
对于Kafka Streams应用程序,您可以观察到2种类型的中间主题:-重新分区和-changelog。
-重新分区
-changelog
当您的Kafka Streams应用程序调用更改密钥的命令时,需要-re分区主题。
-re分区
-changelog主题表示一个变更日志状态(当您创建KTables时),其中流中的每个数据记录都捕获表的状态更改。有关详细信息,请参阅二元流和表。