From 3ccf3996a71e0a24ca76ced3f9ead6906d0cfa44 Mon Sep 17 00:00:00 2001
From: leipeng <peng@topling.cn>
Date: Sun, 6 Oct 2024 20:19:14 +0800
Subject: [PATCH] Add KafkaWritableFile::GetFileSize() override

---
 cloud/aws/aws_kafka.cc | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cloud/aws/aws_kafka.cc b/cloud/aws/aws_kafka.cc
index 5e28f35d0..c79e27c11 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);