Skip to content

Commit c9d8a05

Browse files
authored
Update RedeliveryTracker.java
1 parent 742c37f commit c9d8a05

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

core/src/main/java/com/softwaremill/kmq/RedeliveryTracker.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,10 @@
22

33
import com.softwaremill.kmq.redelivery.RedeliveryActors;
44

5+
import scala.Option;
6+
57
import java.io.Closeable;
8+
import java.util.Map;
69

710
/**
811
* Tracks which messages has been processed, and redelivers the ones which are not processed until their redelivery
@@ -12,4 +15,8 @@ public class RedeliveryTracker {
1215
public static Closeable start(KafkaClients clients, KmqConfig config) {
1316
return RedeliveryActors.start(clients, config);
1417
}
18+
19+
public static Closeable start(KafkaClients clients, KmqConfig config, Option<Map<String, Object>> extraConfig) {
20+
return RedeliveryActors.start(clients, config, extraConfig);
21+
}
1522
}

0 commit comments

Comments
 (0)