Process replicated ack regardless of store update. Delay but still st…

…epdown

Signed-off-by: Derek Collison <derek@nats.io>

server/jetstream_cluster.go

@@ -4525,11 +4525,9 @@ func (o *consumer) processReplicatedAck(dseq, sseq uint64) {
 
 	// Update activity.
 	o.lat = time.Now()
+
 	// Do actual ack update to store.
-	if err := o.store.UpdateAcks(dseq, sseq); err != nil {
-		o.mu.Unlock()
-		return
-	}
+	o.store.UpdateAcks(dseq, sseq)
 
 	if o.retention == LimitsPolicy {
 		o.mu.Unlock()

server/raft.go

@@ -1352,6 +1352,7 @@ func (n *raft) StepDown(preferred ...string) error {
 	if maybeLeader != noLeader {
 		n.debug("Selected %q for new leader", maybeLeader)
 		prop.push(&Entry{EntryLeaderTransfer, []byte(maybeLeader)})
+		time.AfterFunc(250*time.Millisecond, func() { stepdown.push(noLeader) })
 	} else {
 		// Force us to stepdown here.
 		n.debug("Stepping down")