bulker: disable consumers for stale topics

jitsucom · Jan 16, 2024 · e414e24 · e414e24
1 parent 525fe5d
commit e414e24
Showing 1 changed file with 14 additions and 14 deletions.
diff --git a/bulkerapp/app/topic_manager.go b/bulkerapp/app/topic_manager.go
@@ -142,20 +142,20 @@ func (tm *TopicManager) LoadMetadata() {
 			}
 		}
 	}
-	start := time.Now()
-	res, err := tm.kaftaAdminClient.ListOffsets(context.Background(), topicPartitionOffsets)
-	if err != nil {
-		tm.Errorf("Error getting topic offsets: %v", err)
-	} else {
-		for tp, offset := range res.ResultInfos {
-			if offset.Offset >= 0 {
-				topicsLastMessageDates[*tp.Topic] = time.UnixMilli(offset.Timestamp)
-			} else {
-				topicsLastMessageDates[*tp.Topic] = time.Time{}
-			}
-		}
-	}
-	tm.Infof("Got topic offsets in %v", time.Since(start))
+	//start := time.Now()
+	//res, err := tm.kaftaAdminClient.ListOffsets(context.Background(), topicPartitionOffsets)
+	//if err != nil {
+	//	tm.Errorf("Error getting topic offsets: %v", err)
+	//} else {
+	//	for tp, offset := range res.ResultInfos {
+	//		if offset.Offset >= 0 {
+	//			topicsLastMessageDates[*tp.Topic] = time.UnixMilli(offset.Timestamp)
+	//		} else {
+	//			topicsLastMessageDates[*tp.Topic] = time.Time{}
+	//		}
+	//	}
+	//}
+	//tm.Infof("Got topic offsets in %v", time.Since(start))
 
 	if err != nil {
 		metrics.TopicManagerError("load_metadata_error").Inc()