diff --git a/roles/kafka_broker/tasks/get_meta_properties.yml b/roles/kafka_broker/tasks/get_meta_properties.yml
index 73b27052ae..6caa1a8cb8 100644
--- a/roles/kafka_broker/tasks/get_meta_properties.yml
+++ b/roles/kafka_broker/tasks/get_meta_properties.yml
@@ -6,7 +6,8 @@
   register: uuid_broker
 
 - name: Format Storage Directory
-  shell: "{{ binary_base_path }}/bin/kafka-storage  format -t={{ clusterid }} -c {{ kafka_broker.config_file }} --ignore-formatted"
+  shell: "{{ binary_base_path }}/bin/kafka-storage format -t={{ clusterid }} -c {{ kafka_broker.config_file }} --ignore-formatted"
   register: format_meta
+  changed_when: format_meta.stdout_lines is not search('already formatted', multiline=true)
   vars:
     clusterid: "{{ (uuid_broker['content'] | b64decode).partition('cluster.id=')[2].partition('\n')[0] }}"
diff --git a/roles/kafka_controller/tasks/get_meta_properties.yml b/roles/kafka_controller/tasks/get_meta_properties.yml
index 02c9689db0..c193ea0cd9 100644
--- a/roles/kafka_controller/tasks/get_meta_properties.yml
+++ b/roles/kafka_controller/tasks/get_meta_properties.yml
@@ -3,12 +3,14 @@
   shell: "{{ binary_base_path }}/bin/kafka-storage info -c {{ kafka_controller.config_file }}"
   ignore_errors: true
   failed_when: false
+  changed_when: false
   register: formatted
 
 - name: Get ClusterId
   shell: "{{ binary_base_path }}/bin/kafka-storage random-uuid"
   environment:
     KAFKA_OPTS: "-Xlog:all=error -XX:+IgnoreUnrecognizedVMOptions"
+  changed_when: false
   register: uuid_key
   run_once: true
   when: not kraft_migration|bool