我找不到一种方法来确保旧消息不会在使用者读取之前从日志中删除
LogCleaner按照自己的时间表运行，并且仅在封闭段上运行，或者对于压缩主题，dirty+封闭段，其中“dirty”被定义为具有新键的旧值。
消费者将检索同一密钥的所有消息
压缩会主动删除这些数据。你需要手动将这些数据聚合到一个列表中，而不是让Kafka通过压缩删除这些值。
因此，一种方法是使用两个主题，首先使用常规数据作为压缩主题

(k1, v1)
(k2, v2)
(k1, v3)

然后某个进程使用它并构建自己的流

(k1, [v1])
(k2, [v2])
(k1, [v1, v3])

这也是紧凑的，所以第一个k1最终会被删除，但是您有所有以前值的历史记录，当在其上构建KTable时，您可以通过键查找所有值
其他解决方案-如果Kafka中没有足够的存储空间来保存所有这些值，则将数据转储到外部数据库表。假设您的数据库将有更多的存储空间