diff --git a/controllers/jetstream/consumer.go b/controllers/jetstream/consumer.go
index 3bf9cc72..da5332ce 100644
--- a/controllers/jetstream/consumer.go
+++ b/controllers/jetstream/consumer.go
@@ -172,7 +172,7 @@ func (c *Controller) processConsumerObject(cns *apis.Consumer, jsmc jsmClient) (
 		return err
 	}
 	updateOK := (consumerOK && !deleteOK && newGeneration)
-	createOK := (!consumerOK && !deleteOK && newGeneration)
+	createOK := (!consumerOK && !deleteOK)
 
 	switch {
 	case createOK:
diff --git a/controllers/jetstream/stream.go b/controllers/jetstream/stream.go
index 4896fb85..02bb1023 100644
--- a/controllers/jetstream/stream.go
+++ b/controllers/jetstream/stream.go
@@ -211,7 +211,7 @@ func (c *Controller) processStreamObject(str *apis.Stream, jsmc jsmClient) (err
 		return err
 	}
 	updateOK := (strOK && !deleteOK && newGeneration)
-	createOK := (!strOK && !deleteOK && newGeneration)
+	createOK := (!strOK && !deleteOK)
 
 	switch {
 	case createOK: