Nats kv config (#156)

* events/nats: create consumer if it doesn't exist instead of returning the error * events/kv: Add config parameters * Revert "events/kv: Add config parameters" This reverts commit 16cb09f.
metal-toolbox · Sep 25, 2023 · cd7478a · cd7478a
1 parent 6e778f6
commit cd7478a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/events/nats.go b/events/nats.go
@@ -223,7 +223,11 @@ func (n *NatsJetstream) addConsumer() error {
 	for name := range n.jsctx.ConsumerNames(n.parameters.Stream.Name) {
 		consumerInfo, err := n.jsctx.ConsumerInfo(n.parameters.Stream.Name, n.parameters.Consumer.Name)
 		if err != nil {
-			return errors.Wrap(err, ErrNatsJetstreamAddConsumer.Error())
+			if errors.Is(err, nats.ErrConsumerNotFound) {
+				break
+			}
+
+			return errors.Wrap(err, ErrNatsJetstreamAddConsumer.Error()+" consumer.Name="+n.parameters.Consumer.Name)
 		}
 
 		if name == n.parameters.Consumer.Name && !n.consumerConfigIsEqual(consumerInfo) {