Skip to content

Commit

Permalink
Leave after syncing
Browse files Browse the repository at this point in the history
  • Loading branch information
@mkuratczyk
mkuratczyk committed Nov 22, 2024
1 parent d2ad08a commit d149b04
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions cmd/root.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -406,6 +406,8 @@ func join_cluster(expectedInstance int, serviceName string) {
time.Sleep(time.Second)
}

list.Leave(time.Second)

Check failure on line 409 in cmd/root.go

View workflow job for this annotation

GitHub Actions / Lint 

Error return value of `list.Leave` is not checked (errcheck)
list.Shutdown()

Check failure on line 410 in cmd/root.go

View workflow job for this annotation

GitHub Actions / Lint 

Error return value of `list.Shutdown` is not checked (errcheck)
}

func startConsumers(ctx context.Context, consumerProto config.Protocol, wg *sync.WaitGroup) {
Expand Down

0 comments on commit d149b04

Please sign in to comment.