我正在alpakka中使用consumer.commitablesource进行数据复制。但是，kafka日志文件的大小增长很快。一天的大小达到5GB。为了解决这个问题，ı 要立即删除已处理的数据。我在adminclient中使用delete record方法来删除偏移量。但是当我查看日志文件时，与该偏移量对应的数据并没有被删除。
9o685dep1#
使用时 commitableSource 您需要确认记录已被成功读取，并且已准备好通过提交偏移量进行清理。你可以打电话给我 commitJavadsl() . 有关更多信息，请参阅文档中的示例。
commitableSource
commitJavadsl()
1条答案
按热度按时间9o685dep1#
使用时
commitableSource您需要确认记录已被成功读取，并且已准备好通过提交偏移量进行清理。你可以打电话给我commitJavadsl(). 有关更多信息，请参阅文档中的示例。