diff --git a/src/consumer/multi.rs b/src/consumer/multi.rs
index d0fae2e..5dc34d8 100644
--- a/src/consumer/multi.rs
+++ b/src/consumer/multi.rs
@@ -383,7 +383,11 @@ impl<T: 'static + DeserializeMessage, Exe: Executor> Stream for MultiTopicConsum
                             "Unexpected error consuming from pulsar topic {}: {}",
                             &topic, e
                         );
-                        topics_to_remove.push(topic.clone());
+                        // Only remove topic from MultiTopicConsumer on error if they
+                        // can be re-added later by regex
+                        if self.topic_regex.is_some() {
+                            topics_to_remove.push(topic.clone());
+                        }
                     }
                 }
             } else {