java - 如何减少 Alpakka 的 Kafka 日志文件大小

Question

我正在使用 Consumer.commitableSource 在 alpakka 中进行数据复制。但是，kafka 日志文件的大小增加得非常快。一天的大小达到 5 GB。作为这个问题的解决方案，我想立即删除处理过的数据。我在 AdminClient 中使用删除记录方法来删除偏移量。但是当我查看日志文件时，与该偏移量对应的数据并没有被删除。

Answer 1

使用时，commitableSource您需要确认记录已成功读取并准备好通过提交偏移量进行清理。你可以通过调用来做到这一点commitJavadsl()。查看文档中的示例以获取更多信息。