diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 3170cb77eb..b784e71e88 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -287,6 +287,7 @@ func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Cons // keyExist = rmq.checkKeyExist(key) // } // } + if rmq.checkKeyExist(key) { if vals, ok := rmq.consumers.Load(topicName); ok { for _, v := range vals.([]*Consumer) { diff --git a/scripts/run_go_codecov.sh b/scripts/run_go_codecov.sh index c9d5f25a44..9110b10147 100755 --- a/scripts/run_go_codecov.sh +++ b/scripts/run_go_codecov.sh @@ -4,7 +4,7 @@ set -e echo "" > coverage.txt for d in $(go list ./internal... | grep -v vendor); do - go test -race -coverprofile=profile.out -covermode=atomic "$d" + go test -race -coverpkg=./... -coverprofile=profile.out -covermode=atomic "$d" if [ -f profile.out ]; then cat profile.out >> coverage.txt rm profile.out