Add KafkaWritableFile::GetFileSize() override

topling · Oct 6, 2024 · 3ccf399 · 3ccf399
1 parent a01782e
commit 3ccf399
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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);