From bca036a2a4d09efc3e16054595e5976491f4f4fd Mon Sep 17 00:00:00 2001 From: wk989898 Date: Tue, 3 Dec 2024 18:45:03 +0800 Subject: [PATCH] . --- cmd/kafka-consumer/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/kafka-consumer/consumer.go b/cmd/kafka-consumer/consumer.go index 859c7100e73..97eb971b9ad 100644 --- a/cmd/kafka-consumer/consumer.go +++ b/cmd/kafka-consumer/consumer.go @@ -128,7 +128,7 @@ func (c *consumer) Consume(ctx context.Context) { select { case <-ctx.Done(): log.Info("consumer exist: context cancelled") - break + return default: } msg, err := c.client.ReadMessage(-1)