diff --git a/src/main/java/software/amazon/cloudformation/loggers/CloudWatchLogPublisher.java b/src/main/java/software/amazon/cloudformation/loggers/CloudWatchLogPublisher.java
index 75ca8e45..be446769 100644
--- a/src/main/java/software/amazon/cloudformation/loggers/CloudWatchLogPublisher.java
+++ b/src/main/java/software/amazon/cloudformation/loggers/CloudWatchLogPublisher.java
@@ -69,6 +69,7 @@ protected void publishMessage(final String message) {
             assert cloudWatchLogsClient != null : "cloudWatchLogsClient was not initialised. "
                 + "You must call refreshClient() first.";
             PutLogEventsResponse putLogEventsResponse = cloudWatchLogsClient.putLogEvents(PutLogEventsRequest.builder()
+                .overrideConfiguration(builder -> builder.putHeader("x-amzn-logs-format", "json/emf"))
                 .sequenceToken(nextSequenceToken).logGroupName(logGroupName).logStreamName(logStreamName)
                 .logEvents(InputLogEvent.builder().message(message).timestamp(new Date().getTime()).build()).build());