feat: 调整可用的kafka数量 --story=118520992 (#438)

TencentBlueKing · Jul 16, 2024 · 24fa681 · 24fa681
1 parent 9606031
commit 24fa681
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/bk-monitor-worker/internal/metadata/task/config_refresh.go b/pkg/bk-monitor-worker/internal/metadata/task/config_refresh.go
@@ -391,6 +391,7 @@ func RefreshKafkaTopicInfo(ctx context.Context, t *t.Task) error {
 		clusterId, ok := dataIdClusterId[info.BkDataId]
 		if !ok {
 			logger.Infof("data_id [%v] not found in data_id_cluster_id map, skip", info.BkDataId)
+			wg.Done()
 			continue
 		}
 		// 获取 kafka 集群信息
@@ -402,6 +403,7 @@ func RefreshKafkaTopicInfo(ctx context.Context, t *t.Task) error {
 		clusterInfo, ok := clusterInfoMap[clusterId]
 		if !ok && kafkaClient == nil {
 			logger.Infof("data_id [%v] and cluster_id [%s] not found cluster info, skip", info.BkDataId, clusterId)
+			wg.Done()
 			continue
 		}