bulker: disable stale topics logic by default

jitsucom · Oct 2, 2024 · 0d4987e · 0d4987e
1 parent 7907a34
commit 0d4987e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/bulkerapp/app/topic_manager.go b/bulkerapp/app/topic_manager.go
@@ -194,6 +194,7 @@ func (tm *TopicManager) processMetadata(metadata *kafka.Metadata, nonEmptyTopics
 			abandonedTopicsCount++
 			continue
 		}
+		var ok bool
 		if tm.config.StaleTopics {
 			lastMessageDate, ok := tm.topicLastActiveDate[topic]
 			if !ok || lastMessageDate.Before(staleTopicsCutOff) {