Fix java type for event_time (#1023)

Signed-off-by: Marvin Froeder <marvin@datasqrl.com>
DataSQRL · Dec 11, 2024 · b34a32d · b34a32d
1 parent 63c6dc9
commit b34a32d
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);
               })