压缩主题：日志清理器和抵消消耗
一个与主题压缩有关的问题。在压缩主题中，当日志清理器在清理特定键的以前偏移量（3,4,5）时出现延迟（假设5是最新的偏移量），而作为使用者使用这些偏移量时，即使3和4还没有压缩，我会只看到该键的最新偏移量（5）吗？还是使用者将按照该顺序获得（3,4,5）？
共有1个答案
如果3和4还没有被压缩出主题，您的消费者将得到(3，4，5)。如果您在3是最新消息时订阅，然后在随后发布的4和5中订阅，这与您将获得的结果相同，因此它不应该破坏您的消费者逻辑。此外，压缩不会在每个主题分区的最新段上运行，因为这些段文件仍然为写打开。这意味着不能保证每个键只存在于一个消息上。
-
我有一个带有Kafka使用者的spring应用程序，它使用@KafKalisterner注释。正在使用的主题是日志压缩的，我们可能会遇到必须再次使用主题消息的情况。以编程方式实现这一目标的最佳方法是什么？我们不控制Kafka主题配置。
-
我有一个关于Kafka主题清理策略和它们的日志.保留... 例如，如果我将cleanup.policy设置为compact，则只有在主题的保留时间或保留时间对压缩没有影响之后才会开始压缩？ 答案Thx...
-
我在一个输入主题上构建KTable，并且在两个Kafka Stream应用程序实例上加入KStream。 KTable的输入主题已经是一个日志压缩主题。因此，当我的一个应用程序实例关闭时，通过读取input log compacted主题，另一个实例状态存储似乎会用整个状态刷新。 所以不需要为我的KTable存储启用日志记录（更改日志）？ 我的源输入日志压缩主题可能有数百万条记录，所以如果我在KT
-
我在《掌握Kafka Streams and ksqlDB》一书中遇到了以下两个短语，作者使用了两个术语，它们的真正含义是“压缩主题”和“未压缩主题” 他们对“日志压缩”有什么看法吗？ 表可以被认为是对数据库的更新。在日志的这种视图中，只保留每个键的当前状态（给定键的最新记录或某种聚合）。表通常是从压缩的主题构建的。 用数据库的说法，流可以被视为插入。每个不同的记录都保留在此日志视图中。流通常是从
-
我需要压缩Weblogic日志。 我检查了Weblogic控制台的日志设置，发现我可以旋转日志，但没有看到可以为日志压缩（压缩到zip文件）设置的任何属性。 当前设置如图所示。 有没有自动压缩这些日志的方法？
-
日志压缩可确保 Kafka 始终至少为单个 topic partition 的数据日志中的每个 message key 保留最新的已知值。 这样的设计解决了应用程序崩溃、系统故障后恢复或者应用在运行维护过程中重启后重新加载缓存的场景。 接下来让我们深入讨论这些在使用过程中的更多细节，阐述在这个过程中它是如何进行日志压缩的。 迄今为止，我们只介绍了简单的日志保留方法（当旧的数据保留时间超过指定时间、