From 7719048161eededeaa0394f06ae8d0ef5389e5d2 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 2 Feb 2022 11:41:08 +0000 Subject: [PATCH] Only nuke consumers if they are push consumers --- setup/jetstream/helpers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/setup/jetstream/helpers.go b/setup/jetstream/helpers.go index 0354d8647..ec7fc8728 100644 --- a/setup/jetstream/helpers.go +++ b/setup/jetstream/helpers.go @@ -13,7 +13,7 @@ func JetStreamConsumer( f func(ctx context.Context, msg *nats.Msg) bool, opts ...nats.SubOpt, ) error { - if _, err := nats.ConsumerInfo(subj, durable); err == nil { + if cinfo, err := nats.ConsumerInfo(subj, durable); err == nil && cinfo.PushBound { if err := nats.DeleteConsumer(subj, durable); err != nil { return fmt.Errorf("nats.DeleteConsumer: %w", err) }