diff --git a/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java b/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
index e86b3e9..e1bdebb 100644
--- a/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
+++ b/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
@@ -120,8 +120,8 @@ public abstract class KafkaConsumer<K> {
 						return new Timestamped<>(1, record.value());
 					}
 				})
-				.transform(ReactorUtils::subscribeOnce)
 				.transform(this::retryIfCleanup)
-				.transform(this::retryIfCommitFailed);
+				.transform(this::retryIfCommitFailed)
+				.transform(ReactorUtils::subscribeOnce);
 	}
 }