diff --git a/src/webclient.c b/src/webclient.c
index 7182418..410dd97 100644
--- a/src/webclient.c
+++ b/src/webclient.c
@@ -1139,6 +1139,7 @@ int webclient_shard_position_function(struct webclient_session *session, const c
                     if(webclient_connect(session, URI) == WEBCLIENT_OK)
                     {
                         LOG_D("webclient reconnect success, retry at [%06d]", end_position);
+                        end_position = start_position;
                         continue;
                     }
                     else