Fix java type for event_time

Signed-off-by: Marvin Froeder <marvin@datasqrl.com>
DataSQRL · Dec 4, 2024 · 64e3c13 · 64e3c13
1 parent 6bc0452
commit 64e3c13
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...erver/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java b/...erver/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java
@@ -69,7 +69,7 @@ public DataFetcher<?> visit(KafkaMutationCoords coords, Context context) {
               .onSuccess(sinkResult->{
                 //Add timestamp from sink to result
                 ZonedDateTime dateTime = ZonedDateTime.ofInstant(sinkResult.getSourceTime(), ZoneOffset.UTC);
-                entry.put(ReservedName.MUTATION_TIME.getCanonical(), dateTime.toLocalDateTime());
+                entry.put(ReservedName.MUTATION_TIME.getCanonical(), dateTime.toOffsetDateTime());
 
                 fut.complete(entry);
               })