diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
index a8e08c5d9..0fe7b9773 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
@@ -135,7 +135,7 @@ class FunctionInvoker<I, O> implements Function<Flux<Message<I>>, Flux<Message<O
 						onError(e, originalMessageRef.get());
 						return Mono.empty();
 					});
-		}).log().map(resultMessage -> toMessage(resultMessage, originalMessageRef.get())); // create
+		}).map(resultMessage -> toMessage(resultMessage, originalMessageRef.get())); // create
 																							// output
 																							// message
 	}