diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.java index 35149a36b..4a6d944eb 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.java @@ -109,7 +109,9 @@ public class ContextFunctionCatalogAutoConfiguration { if (!CollectionUtils.isEmpty(messageConverters)) { for (MessageConverter mc : messageConverters) { if (mc instanceof CompositeMessageConverter) { - mcList.addAll(((CompositeMessageConverter) mc).getConverters()); + List conv = ((CompositeMessageConverter) mc).getConverters().stream() + .filter(c -> !c.getClass().getSimpleName().equals("ApplicationJsonMessageMarshallingConverter")).collect(Collectors.toList()); + mcList.addAll(conv); } else { mcList.add(mc);