From 7905601e5149c4c422d3d33aaba92ac5f05f2fb3 Mon Sep 17 00:00:00 2001
From: Soby Chacko <chackos@vmware.com>
Date: Mon, 24 Jul 2023 15:14:38 -0400
Subject: [PATCH] DltAwareProcessor constructor changes

---
 .../cloud/stream/binder/kafka/streams/DltAwareProcessor.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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");