diff --git a/src/homelogstore/log_store.cpp b/src/homelogstore/log_store.cpp
index c0b087d8c..d1f1f690a 100644
--- a/src/homelogstore/log_store.cpp
+++ b/src/homelogstore/log_store.cpp
@@ -316,19 +316,23 @@ int HomeLogStore::search_max_le(const logstore_seq_num_t input_sn) {
 
 nlohmann::json HomeLogStore::dump_log_store(const log_dump_req& dump_req) {
     nlohmann::json json_dump{}; // create root object
-    json_dump["store_id"] = this->m_store_id;
-
     const auto trunc_upto{this->truncated_upto()};
     std::remove_const_t< decltype(trunc_upto) > idx{trunc_upto + 1};
+    int32_t batch_size;
+    if (dump_req.batch_size != 0) {
+        batch_size = dump_req.batch_size;
+    } else {
+        batch_size = dump_req.end_seq_num - dump_req.start_seq_num;
+    }
     if (dump_req.start_seq_num != 0) idx = dump_req.start_seq_num;
 
     // must use move operator= operation instead of move copy constructor
     nlohmann::json json_records = nlohmann::json::array();
-    bool end_iterate{false};
+    bool proceed{false};
     m_records.foreach_completed(
         idx,
-        [&json_records, &dump_req, &end_iterate, this](decltype(idx) cur_idx, decltype(idx) max_idx,
-                                                       const homestore::logstore_record& record) -> bool {
+        [&batch_size, &json_dump, &json_records, &dump_req, &proceed,
+         this](decltype(idx) cur_idx, decltype(idx) max_idx, const homestore::logstore_record& record) -> bool {
             // do a sync read
             // must use move operator= operation instead of move copy constructor
             nlohmann::json json_val = nlohmann::json::object();
@@ -349,8 +353,10 @@ nlohmann::json HomeLogStore::dump_log_store(const log_dump_req& dump_req) {
 
             json_records.emplace_back(std::move(json_val));
             decltype(idx) end_idx{std::min(max_idx, dump_req.end_seq_num)};
-            end_iterate = (cur_idx < end_idx) ? true : false;
-            return end_iterate;
+            proceed = (cur_idx < end_idx && --batch_size > 0) ? true : false;
+            // User can provide either the end_seq_num or batch_size in the request.
+            if (cur_idx < end_idx && batch_size == 0) { json_dump["next_cursor"] = std::to_string(cur_idx + 1); }
+            return proceed;
         });
 
     json_dump["log_records"] = std::move(json_records);
@@ -379,6 +385,19 @@ logstore_seq_num_t HomeLogStore::get_contiguous_completed_seq_num(const logstore
 
 sisl::status_response HomeLogStore::get_status(const sisl::status_request& request) {
     sisl::status_response response;
+    if (request.json.contains("type") && request.json["type"] == "logstore_record") {
+        log_dump_req dump_req{};
+        if (!request.next_cursor.empty()) { dump_req.start_seq_num = std::stoul(request.next_cursor); }
+        dump_req.batch_size = request.batch_size;
+        dump_req.end_seq_num = UINT32_MAX;
+        homestore::log_dump_verbosity verbose_level = homestore::log_dump_verbosity::HEADER;
+        if (request.json.contains("log_content")) { verbose_level = homestore::log_dump_verbosity::CONTENT; }
+        dump_req.verbosity_level = verbose_level;
+        response.json.update(dump_log_store(dump_req));
+        return response;
+    }
+
+    response.json["store_id"] = this->m_store_id;
     response.json["append_mode"] = m_append_mode;
     response.json["highest_lsn"] = m_seq_num.load(std::memory_order_relaxed);
     response.json["max_lsn_in_prev_flush_batch"] = m_flush_batch_max_lsn;
@@ -400,6 +419,7 @@ sisl::status_response HomeLogStore::get_status(const sisl::status_request& reque
         dump_req.verbosity_level = verbose_level;
         response.json.update(dump_log_store(dump_req));
     }
+
     return response;
 }
 
diff --git a/src/homelogstore/log_store.hpp b/src/homelogstore/log_store.hpp
index b7b0b8b04..0dfb8c838 100644
--- a/src/homelogstore/log_store.hpp
+++ b/src/homelogstore/log_store.hpp
@@ -45,6 +45,7 @@ struct log_dump_req {
     std::shared_ptr< HomeLogStore > log_store; // if null all log stores are dumped
     logstore_seq_num_t start_seq_num;          // empty_key if from start of log file
     logstore_seq_num_t end_seq_num;            // empty_key if till last log entry
+    int32_t batch_size = 0;                    // Size of the output batch.
 };
 
 struct logstore_record {
diff --git a/src/homelogstore/log_store_family.cpp b/src/homelogstore/log_store_family.cpp
index 988921cb7..3b4a8cd8a 100644
--- a/src/homelogstore/log_store_family.cpp
+++ b/src/homelogstore/log_store_family.cpp
@@ -34,9 +34,6 @@ LogStoreFamily::LogStoreFamily(const logstore_family_id_t f_id) :
         m_family_id{f_id},
         m_metablk_name{std::string("LogStoreFamily") + std::to_string(f_id)},
         m_log_dev{f_id, m_metablk_name} {
-    auto hb = HomeStoreBase::safe_instance();
-    m_sobject = hb->sobject_mgr()->create_object("LogStoreFamily", m_metablk_name,
-                                                 std::bind(&LogStoreFamily::get_status, this, std::placeholders::_1));
 }
 
 void LogStoreFamily::meta_blk_found_cb(meta_blk* const mblk, const sisl::byte_view buf, const size_t size) {
@@ -44,6 +41,10 @@ void LogStoreFamily::meta_blk_found_cb(meta_blk* const mblk, const sisl::byte_vi
 }
 
 void LogStoreFamily::start(const bool format, JournalVirtualDev* blk_store) {
+    auto hb = HomeStoreBase::safe_instance();
+    m_sobject = hb->sobject_mgr()->create_object("LogStoreFamily", m_metablk_name,
+                                                 std::bind(&LogStoreFamily::get_status, this, std::placeholders::_1));
+
     m_log_dev.register_store_found_cb(bind_this(LogStoreFamily::on_log_store_found, 2));
     m_log_dev.register_append_cb(bind_this(LogStoreFamily::on_io_completion, 5));
     m_log_dev.register_logfound_cb(bind_this(LogStoreFamily::on_logfound, 6));