diff --git a/codecov.yml b/codecov.yml new file mode 100644 index 0000000000..39257619ee --- /dev/null +++ b/codecov.yml @@ -0,0 +1,33 @@ +coverage: + status: + project: + default: + # basic + target: auto + threshold: 0% + base: auto + flags: + - unit + paths: + - "src" + # advanced settings + branches: + - master + if_ci_failed: error #success, failure, error, ignore + informational: false + only_pulls: false + patch: + # basic + target: 70% + threshold: 0% + base: auto + flags: + - unit + paths: + - "src" + # advanced settings + branches: + - master + if_ci_failed: failure #success, failure, error, ignore + informational: false + only_pulls: false 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) {