From 54fe8cb14f6396e837da0bdbe9671da9be6b26d5 Mon Sep 17 00:00:00 2001
From: Tomasz Pietrek <tomasz@nats.io>
Date: Tue, 8 Aug 2023 09:16:44 +0200
Subject: [PATCH] Fix race in consumer create

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
---
 server/jetstream_cluster.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go
index 89a23257..ca125a6c 100644
--- a/server/jetstream_cluster.go
+++ b/server/jetstream_cluster.go
@@ -6897,6 +6897,7 @@ func (s *Server) jsClusteredConsumerRequest(ci *ClientInfo, acc *Account, subjec
 			if action == ActionCreate && !reflect.DeepEqual(cfg, ca.Config) {
 				resp.Error = NewJSConsumerAlreadyExistsError()
 				s.sendAPIErrResponse(ci, acc, subject, reply, string(rmsg), s.jsonResponse(&resp))
+				return
 			}
 			// Do quick sanity check on new cfg to prevent here if possible.
 			if err := acc.checkNewConsumerConfig(ca.Config, cfg); err != nil {