diff --git a/src/include/homestore/replication/repl_dev.h b/src/include/homestore/replication/repl_dev.h
index 6028ebbb0..70c786df7 100644
--- a/src/include/homestore/replication/repl_dev.h
+++ b/src/include/homestore/replication/repl_dev.h
@@ -59,7 +59,7 @@ using fetch_data_handler_t = folly::Future< std::error_code > (*)(int64_t lsn, c
                                                                   std::vector< sisl::sg_list >& sgs_vec);
 using no_space_left_handler_t = folly::Future< folly::Unit > (*)(uint32_t pdev_id, chunk_num_t chunk_id);
 
-using log_replay_done_handler_t = void (*)();
+using log_replay_done_handler_t = void (*)(const group_id_t& group_id);
 
 // magic num comes from the first 8 bytes of 'echo homestore_resync_data | md5sum'
 static constexpr uint64_t HOMESTORE_RESYNC_DATA_MAGIC = 0xa65dbd27c213f327;
diff --git a/src/lib/replication/service/raft_repl_service.cpp b/src/lib/replication/service/raft_repl_service.cpp
index df89a5b6c..c0a97e38c 100644
--- a/src/lib/replication/service/raft_repl_service.cpp
+++ b/src/lib/replication/service/raft_repl_service.cpp
@@ -165,7 +165,7 @@ void RaftReplService::start() {
         if (auto listener = rdev->get_listener(); listener) {
             if (auto log_replay_done_handler = listener->get_event_handler(event_type_t::RD_LOG_REPLAY_DONE);
                 log_replay_done_handler) {
-                reinterpret_cast< log_replay_done_handler_t >(log_replay_done_handler)();
+                reinterpret_cast< log_replay_done_handler_t >(log_replay_done_handler)(rdev->group_id());
             }
         }