diff --git a/include/libnuraft/callback.hxx b/include/libnuraft/callback.hxx
index 5becd4ab..354d2ceb 100644
--- a/include/libnuraft/callback.hxx
+++ b/include/libnuraft/callback.hxx
@@ -188,6 +188,12 @@ public:
          * ctx: null
          */
         AutoAdjustQuorum = 24,
+
+        /**
+         * Adding a server failed due to RPC errors and timeout expiry.
+         * ctx: null
+         */
+        ServerJoinFailed = 25
     };
 
     struct Param {
diff --git a/src/handle_join_leave.cxx b/src/handle_join_leave.cxx
index b8e83f97..19d2ba26 100644
--- a/src/handle_join_leave.cxx
+++ b/src/handle_join_leave.cxx
@@ -596,6 +596,9 @@ void raft_server::handle_join_leave_rpc_err(msg_type t_msg, ptr<peer> p) {
               p->get_id() );
         config_changing_ = false;
         reset_srv_to_join();
+
+        cb_func::Param param(id_, leader_, p->get_id());
+        invoke_callback(cb_func::ServerJoinFailed, &param);
     }
 }
 
diff --git a/tests/unit/raft_package_fake.hxx b/tests/unit/raft_package_fake.hxx
index 0c36f4d5..fd11f296 100644
--- a/tests/unit/raft_package_fake.hxx
+++ b/tests/unit/raft_package_fake.hxx
@@ -230,12 +230,13 @@ static cb_func::ReturnCode ATTR_UNUSED cb_default(
 
 static INT_UNUSED launch_servers(const std::vector<RaftPkg*>& pkgs,
                                  raft_params* custom_params = nullptr,
-                                 bool restart = false) {
+                                 bool restart = false,
+                                 cb_func::func_type callback = cb_default) {
     size_t num_srvs = pkgs.size();
     CHK_GT(num_srvs, 0);
 
     raft_server::init_options opt(false, true, true);
-    opt.raft_callback_ = cb_default;
+    opt.raft_callback_ = callback;
 
     for (size_t ii = 0; ii < num_srvs; ++ii) {
         RaftPkg* ff = pkgs[ii];
diff --git a/tests/unit/raft_server_test.cxx b/tests/unit/raft_server_test.cxx
index c306d5d5..8e03614c 100644
--- a/tests/unit/raft_server_test.cxx
+++ b/tests/unit/raft_server_test.cxx
@@ -283,13 +283,30 @@ int add_node_error_cases_test() {
     std::string s1_addr = "S1";
     std::string s2_addr = "S2";
     std::string s3_addr = "S3";
+    // Hard to make a server really non-existent as to fail an rpc req with a FakeNetwork
+    // you need to actually have a recipient. So we simulate a nonexistent server with an 
+    // offline one
+    std::string nonexistent_addr = "nonexistent";
 
     RaftPkg s1(f_base, 1, s1_addr);
     RaftPkg s2(f_base, 2, s2_addr);
     RaftPkg s3(f_base, 3, s3_addr);
-    std::vector<RaftPkg*> pkgs = {&s1, &s2, &s3};
+    RaftPkg nonexistent(f_base, 4, nonexistent_addr);
+    std::vector<RaftPkg*> pkgs = {&s1, &s2, &s3, &nonexistent};
+
+    bool join_error_callback_fired = false;
+    int join_error_srv_id = -1;
+    auto join_error_callback = [&](cb_func::Type type, cb_func::Param* param) {
+        if (type == cb_func::Type::ServerJoinFailed) {
+            join_error_callback_fired = true;
+            join_error_srv_id = param->peerId;
+            return cb_func::ReturnCode::Ok;
+        }
+        return cb_default(type, param);
+    };
 
-    CHK_Z( launch_servers( pkgs ) );
+    CHK_Z( launch_servers( pkgs, nullptr, false, join_error_callback) );
+    nonexistent.fNet->goesOffline();
 
     size_t num_srvs = pkgs.size();
     CHK_GT(num_srvs, 0);
@@ -438,6 +455,15 @@ int add_node_error_cases_test() {
         CHK_EQ(3, configs_out.size());
     }
 
+    {   // Add a non-existent server to S1, check that a callback is fired on timers expiry.
+        s1.raftServer->add_srv({nonexistent.myId, nonexistent_addr});
+        s1.fNet->execReqResp(nonexistent_addr);
+        s1.fNet->execReqResp(nonexistent_addr);
+
+        CHK_TRUE(join_error_callback_fired);
+        CHK_EQ(nonexistent.myId, join_error_srv_id);
+    }
+
     print_stats(pkgs);
 
     s1.raftServer->shutdown();