Recover in consumer assignment when asset already existed

nats-io · Aug 17, 2023 · 065a65f · 065a65f
1 parent 3c85490
commit 065a65f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go
@@ -4001,7 +4001,7 @@ func (js *jetStream) processClusterCreateConsumer(ca *consumerAssignment, state
 	var didCreate, isConfigUpdate, needsLocalResponse bool
 	if o == nil {
 		// Add in the consumer if needed.
-		if o, err = mset.addConsumerWithAssignment(ca.Config, ca.Name, ca, false); err == nil {
+		if o, err = mset.addConsumerWithAssignment(ca.Config, ca.Name, ca, wasExisting); err == nil {
 			didCreate = true
 		}
 	} else {