From 0d4987ee5c8c7a3ecbe02769dfd566f7c0a09155 Mon Sep 17 00:00:00 2001
From: Ildar Nurislamov <absorbb@gmail.com>
Date: Wed, 2 Oct 2024 20:09:25 +0400
Subject: [PATCH] bulker: disable stale topics logic by default

---
 bulkerapp/app/topic_manager.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/bulkerapp/app/topic_manager.go b/bulkerapp/app/topic_manager.go
index 688da1f..2a43a49 100644
--- 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) {