diff --git a/module_utils/kafka_manager.py b/module_utils/kafka_manager.py
index 5fc25d5..f825437 100644
--- a/module_utils/kafka_manager.py
+++ b/module_utils/kafka_manager.py
@@ -1499,16 +1499,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']: {
@@ -1546,10 +1547,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()
@@ -1563,6 +1560,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']: {