Signal a metasnapshot for consumer deletes as well

Signed-off-by: Derek Collison <derek@nats.io>
nats-io · Feb 28, 2023 · 158d357 · 158d357
1 parent ccae674
commit 158d357
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go
@@ -1627,6 +1627,7 @@ func (js *jetStream) applyMetaEntries(entries []*Entry, ru *recoveryUpdates) (bo
 					delete(ru.updateConsumers, key)
 				} else {
 					js.processConsumerRemoval(ca)
+					didRemove = true
 				}
 			case updateStreamOp:
 				sa, err := decodeStreamAssignment(buf[1:])