Skip to content

Commit 9971d00

Browse files
committed
Fix initialisation of kakfa offset manager
1 parent ef2f2f8 commit 9971d00

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-connect-oura-source/src/main/java/org/radarbase/connect/rest/oura/offset/KafkaOffsetManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public void initialize(List<Map<String, Object>> partitions) {
3636
.filter(e -> e.getValue() != null && e.getValue().containsKey(TIMESTAMP_OFFSET_KEY))
3737
.collect(Collectors.toMap(
3838
e -> (String) e.getKey().get("user") + "-" + e.getKey().get("route"),
39-
e -> Instant.ofEpochMilli(((Number) e.getValue().get(TIMESTAMP_OFFSET_KEY)).longValue())));
39+
e -> Instant.ofEpochSecond(((Number) e.getValue().get(TIMESTAMP_OFFSET_KEY)).longValue())));
4040
} else {
4141
logger.warn("Offset storage reader is null, will resume from an empty state.");
4242
}

0 commit comments

Comments
 (0)