diff --git a/cloud/aws/aws_kafka.cc b/cloud/aws/aws_kafka.cc
index 5e28f35d063..c79e27c11d0 100644
--- a/cloud/aws/aws_kafka.cc
+++ b/cloud/aws/aws_kafka.cc
@@ -51,6 +51,10 @@ class KafkaWritableFile : public CloudLogWritableFile {
   IOStatus Flush(const IOOptions& io_opts, IODebugContext* dbg) override;
   IOStatus LogDelete() override;
 
+  uint64_t GetFileSize(const IOOptions&, IODebugContext*) override {
+    return current_offset_;
+  }
+
  private:
   IOStatus ProduceRaw(const std::string& operation_name, const Slice& message);