kafka保留kstream和链接主题

0ejtzxu1  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(334)

我有一个ktable kafka链接到一个主题,但是当对主题进行保留时,消息也会在我的ktable中被删除,是否可以在删除其主题的值时保留ktable的值?

5vf7fwbs

5vf7fwbs1#

changelog主题以无限的保留时间进行日志压缩。在任何时候,如果有一个新事件出现在您的主题中,它将更新该键在ktables中的状态。
在您的场景中,如果您需要使数据在源主题被删除时仍然可用,我建议将ktable发布到某个输出主题中,以使其更稳定。
由于ktable只在应用程序中公开,并且构建在changelog主题之上,因此一旦应用程序消失,除非使用持久状态存储,否则将丢失数据。

相关问题