From f8e879b42366fb1cf4c391713635890fdd7d209d Mon Sep 17 00:00:00 2001
From: sunby <bingyi.sun@zilliz.com>
Date: Mon, 29 Mar 2021 17:48:15 +0800
Subject: [PATCH] Fix high cpu usage in singlenode

Signed-off-by: sunby <bingyi.sun@zilliz.com>
---
 internal/util/rocksmq/client/rocksmq/client_impl.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/internal/util/rocksmq/client/rocksmq/client_impl.go b/internal/util/rocksmq/client/rocksmq/client_impl.go
index d723646587..1ec2356bee 100644
--- a/internal/util/rocksmq/client/rocksmq/client_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/client_impl.go
@@ -93,8 +93,8 @@ func (c *client) Subscribe(options ConsumerOptions) (Consumer, error) {
 }
 
 func consume(ctx context.Context, consumer *consumer) {
-	for { //nolint:gosimple
-		select { //nolint:gosimple
+	for {
+		select {
 		case <-ctx.Done():
 			log.Debug("client finished")
 			return
@@ -126,7 +126,6 @@ func consume(ctx context.Context, consumer *consumer) {
 					Payload: msg[0].Payload,
 				}
 			}
-		default:
 		}
 	}
 }