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