diff --git a/consumer/mongodb-consumer/README.adoc b/consumer/mongodb-consumer/README.adoc
index 93e61ead..cc8e9522 100644
--- a/consumer/mongodb-consumer/README.adoc
+++ b/consumer/mongodb-consumer/README.adoc
@@ -4,11 +4,13 @@ A consumer that allows you to insert records into MongoDB.
 
 ## Beans for injection
 
-You can import `MongoDbConsumerConfiguration` in the application and then inject the following bean.
+You can import `MongoDbConsumerConfiguration` in the application and then inject one of the following beans.
 
-`Function<Message<?>, Mono<Void>> mongodbConsumer`
+`Function<Message<?>, Mono<Void>> mongodbConsumerFunction` - Allows you to subscribe.
 
-You can use `mongodbConsumer` as a qualifier when injecting.
+`Consumer<Message<?>> mongodbConsumer` - Wraps the function as a Consumer with no-op subscriber.
+
+You can use `mongodbConsumer` or `mongodbConsumerFunction` as a qualifier when injecting.
 
 The return value from the function can be ignored as this is used as a consumer to send records to MongoDB.
 
@@ -18,7 +20,7 @@ All configuration properties are prefixed with `mongodb.consumer`.
 
 For more information on the various options available, please see link:src/main/java/org/springframework/cloud/fn/consumer/mongo/MongoDBConsumerProperties.java[MongoDBConsumerProperties].
 
-## Tests
+## Examples
 
 See this link:src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDBConsumerApplicationTests.java[test suite] for the various ways, this consumer is used.
 
diff --git a/consumer/mongodb-consumer/src/main/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerConfiguration.java b/consumer/mongodb-consumer/src/main/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerConfiguration.java
index e2315858..ff270ace 100644
--- a/consumer/mongodb-consumer/src/main/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerConfiguration.java
+++ b/consumer/mongodb-consumer/src/main/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerConfiguration.java
@@ -16,6 +16,7 @@
 
 package org.springframework.cloud.fn.consumer.mongo;
 
+import java.util.function.Consumer;
 import java.util.function.Function;
 
 import reactor.core.publisher.Mono;
@@ -52,7 +53,12 @@ public class MongoDbConsumerConfiguration {
 	}
 
 	@Bean
-	public Function<Message<?>, Mono<Void>> mongodbConsumer(ReactiveMessageHandler mongoConsumerMessageHandler) {
+	public Consumer<Message<?>> mongodbConsumer(Function<Message<?>, Mono<Void>> mongodbConsumerFunction) {
+		return message -> mongodbConsumerFunction.apply(message).subscribe();
+	}
+
+	@Bean
+	public Function<Message<?>, Mono<Void>> mongodbConsumerFunction(ReactiveMessageHandler mongoConsumerMessageHandler) {
 		return mongoConsumerMessageHandler::handleMessage;
 	}
 
diff --git a/consumer/mongodb-consumer/src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerApplicationTests.java b/consumer/mongodb-consumer/src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerApplicationTests.java
index 3a761af7..3290517d 100644
--- a/consumer/mongodb-consumer/src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerApplicationTests.java
+++ b/consumer/mongodb-consumer/src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerApplicationTests.java
@@ -20,12 +20,11 @@ import java.time.Duration;
 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.function.Function;
+import java.util.function.Consumer;
 
 import org.bson.Document;
 import org.junit.jupiter.api.Test;
 import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -42,14 +41,14 @@ import static org.assertj.core.api.Assertions.assertThat;
  */
 @SpringBootTest(properties = {
 		"spring.data.mongodb.port=0",
-		"mongodb.consumer.collection=testing"})
+		"mongodb.consumer.collection=testing" })
 class MongoDbConsumerApplicationTests {
 
 	@Autowired
 	private MongoDbConsumerProperties properties;
 
 	@Autowired
-	private Function<Message<?>, Mono<Void>> mongoDbConsumer;
+	private Consumer<Message<?>> mongodbConsumer;
 
 	@Autowired
 	private ReactiveMongoTemplate mongoTemplate;
@@ -66,10 +65,12 @@ class MongoDbConsumerApplicationTests {
 		Flux<Message<?>> messages = Flux.just(
 				new GenericMessage<>(data1),
 				new GenericMessage<>(data2),
-				new GenericMessage<>("{\"my_data\": \"THE DATA\"}")
-		);
+				new GenericMessage<>("{\"my_data\": \"THE DATA\"}"));
 
-		messages.flatMap(mongoDbConsumer::apply).blockLast(Duration.ofSeconds(10));
+		messages.map(message -> {
+			mongodbConsumer.accept(message);
+			return message;
+		}).blockLast(Duration.ofSeconds(10));
 
 		StepVerifier.create(this.mongoTemplate.findAll(Document.class, properties.getCollection())
 				.sort(Comparator.comparing(d -> d.get("_id").toString())))