diff --git a/ansible/roles/common/templates/conf/filter/00-record_transformer.conf.j2 b/ansible/roles/common/templates/conf/filter/00-record_transformer.conf.j2
index a63fd5e73f..7f173dedfa 100644
--- a/ansible/roles/common/templates/conf/filter/00-record_transformer.conf.j2
+++ b/ansible/roles/common/templates/conf/filter/00-record_transformer.conf.j2
@@ -37,20 +37,6 @@
 </filter>
 
 {% if enable_monasca | bool %}
-# Kolla Fluentd input config configures Fluentd to save all log messages
-# under the 'Payload' field, however the fluentd-monasca plugin assumes
-# that log messages are saved under the 'message' field. Here we map the
-# 'Payload' field to the 'message' field so that log can be forwarded to
-# Monasca.
-<filter *.**>
-  @type record_transformer
-  enable_ruby true
-  <record>
-    message ${record["Payload"]}
-  </record>
-  remove_keys Payload
-</filter>
-
 # Kolla configures Fluentd to extract timestamps from OpenStack service
 # logs, however these timestamps are not saved in the event and are not
 # forwarded to Monasca. Here we save the timestamp which has been
diff --git a/ansible/roles/common/templates/conf/output/00-local.conf.j2 b/ansible/roles/common/templates/conf/output/00-local.conf.j2
index 1837b0c5ce..84389dff37 100644
--- a/ansible/roles/common/templates/conf/output/00-local.conf.j2
+++ b/ansible/roles/common/templates/conf/output/00-local.conf.j2
@@ -27,6 +27,7 @@
        password {{ monasca_agent_password }}
        domain_id default
        project_name {{ monasca_control_plane_project }}
+       message_field_name Payload
     </store>
 {% endif %}
 </match>
@@ -62,6 +63,7 @@
        password {{ monasca_agent_password }}
        domain_id default
        project_name {{ monasca_control_plane_project }}
+       message_field_name Payload
     </store>
 {% endif %}
 </match>
diff --git a/ansible/roles/common/templates/conf/output/02-monasca.conf.j2 b/ansible/roles/common/templates/conf/output/02-monasca.conf.j2
index f495249ec0..420e6cdad7 100644
--- a/ansible/roles/common/templates/conf/output/02-monasca.conf.j2
+++ b/ansible/roles/common/templates/conf/output/02-monasca.conf.j2
@@ -9,5 +9,6 @@
        password {{ monasca_agent_password }}
        domain_id default
        project_name {{ monasca_control_plane_project }}
+       message_field_name Payload
     </store>
 </match>