diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DltAwareProcessor.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DltAwareProcessor.java
index b19348628..37a7c2977 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DltAwareProcessor.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/DltAwareProcessor.java
@@ -65,11 +65,11 @@ public class DltAwareProcessor<KIn, VIn, KOut, VOut> implements Processor<KIn, V
 
 	public DltAwareProcessor(BiFunction<KIn, VIn, KeyValue<KOut, VOut>> delegateFunction,
 							BiConsumer<Record<KIn, VIn>, Exception> processorRecordRecoverer) {
-		this(delegateFunction, System::currentTimeMillis, processorRecordRecoverer);
+		this(delegateFunction, processorRecordRecoverer, System::currentTimeMillis);
 	}
 
 	public DltAwareProcessor(BiFunction<KIn, VIn, KeyValue<KOut, VOut>> delegateFunction,
-							Supplier<Long> recordTimeSupplier, BiConsumer<Record<KIn, VIn>, Exception> processorRecordRecoverer) {
+							BiConsumer<Record<KIn, VIn>, Exception> processorRecordRecoverer, Supplier<Long> recordTimeSupplier) {
 		this.delegateFunction = delegateFunction;
 		this.recordTimeSupplier = recordTimeSupplier;
 		Assert.notNull(processorRecordRecoverer, "You must provide a valid processor recoverer");