diff --git a/bulkerapp/app/topic_manager.go b/bulkerapp/app/topic_manager.go
index 6edf33e..5c6c1ab 100644
--- a/bulkerapp/app/topic_manager.go
+++ b/bulkerapp/app/topic_manager.go
@@ -316,7 +316,7 @@ func (tm *TopicManager) processMetadata(metadata *kafka.Metadata, lastMessageDat
 			}
 			for _, table := range tables {
 				topicId, _ := MakeTopicId(destination.Id(), "batch", table, false)
-				if !hasTopics || !dstTopics.Contains(topicId) {
+				if (!hasTopics || !dstTopics.Contains(topicId)) && !staleTopics.Contains(topicId) {
 					tm.Infof("Creating topic %s for destination %s", topicId, destination.Id())
 					err := tm.createDestinationTopic(topicId, nil)
 					if err != nil {