diff --git a/src/main/java/de/telekom/horizon/galaxy/kafka/PublishedMessageTask.java b/src/main/java/de/telekom/horizon/galaxy/kafka/PublishedMessageTask.java
index 2f2b23c..3ad09de 100644
--- a/src/main/java/de/telekom/horizon/galaxy/kafka/PublishedMessageTask.java
+++ b/src/main/java/de/telekom/horizon/galaxy/kafka/PublishedMessageTask.java
@@ -381,7 +381,7 @@ private Map<String, FilterEventMessageWrapper> getFilteredEventMessagesPerRecipi
             JsonNode jsonEventDataOrNull = null;
 
             var dataContentType = publishedEventMessage.getEvent().getDataContentType();
-            var jsonMediaTypeRegexPattern = Pattern.compile("^application/(?:[a-zA-Z0-9]+\\+)?json$", Pattern.CASE_INSENSITIVE);
+            var jsonMediaTypeRegexPattern = Pattern.compile("^application/(?:[a-zA-Z0-9]+\\+)?json.*", Pattern.CASE_INSENSITIVE);
 
             if (eventData != null && (dataContentType == null || jsonMediaTypeRegexPattern.matcher(dataContentType.trim()).matches())) {
                 jsonEventDataOrNull = parseEventData(eventData);