From d149b04c593bf751c35fe6131ab572cec2465468 Mon Sep 17 00:00:00 2001 From: Michal Kuratczyk Date: Fri, 22 Nov 2024 11:45:39 +0100 Subject: [PATCH] Leave after syncing --- cmd/root.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cmd/root.go b/cmd/root.go index fcf3f26..ff8b2cc 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -406,6 +406,8 @@ func join_cluster(expectedInstance int, serviceName string) { time.Sleep(time.Second) } + list.Leave(time.Second) + list.Shutdown() } func startConsumers(ctx context.Context, consumerProto config.Protocol, wg *sync.WaitGroup) {