diff --git a/module_utils/kafka_manager.py b/module_utils/kafka_manager.py
index 092bac88..6a257262 100644
--- a/module_utils/kafka_manager.py
+++ b/module_utils/kafka_manager.py
@@ -1573,16 +1573,17 @@ def get_topics_to_update(self, topics):
                         topic['name']
                     )
                 )
-        topics = [
-            topic for topic in topics if (
-                topic['partitions'] > 0 and topic['replica_factor'] > 0)
-        ]
         topics_changed.update(
             self.is_topics_configuration_need_update({
                 topic['name']: topic['options'].items()
                 for topic in topics
             })
         )
+
+        topics = [
+            topic for topic in topics if (
+                topic['partitions'] > 0 and topic['replica_factor'] > 0)
+        ]
         topics_changed.update(
             self.is_topics_replication_need_update({
                 topic['name']: {
@@ -1620,11 +1621,6 @@ def ensure_topics(self, topics):
                     )
                 )
 
-        topics = [
-            topic for topic in topics if (
-                topic['partitions'] > 0 and topic['replica_factor'] > 0)
-        ]
-
         topics_config_need_update = self.is_topics_configuration_need_update({
             topic['name']: topic['options'].items()
             for topic in topics
@@ -1637,6 +1633,10 @@ def ensure_topics(self, topics):
             })
             topics_changed.update(topics_config_need_update)
 
+        topics = [
+            topic for topic in topics if (
+                topic['partitions'] > 0 and topic['replica_factor'] > 0)
+        ]
         topics_replication_need_update = \
             self.is_topics_replication_need_update({
                 topic['name']: {