diff --git a/backend/runner/pubsub/testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java b/backend/runner/pubsub/testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java
index 8eea7135e1..cd67c8b049 100644
--- a/backend/runner/pubsub/testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java
+++ b/backend/runner/pubsub/testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java
@@ -21,7 +21,7 @@ void consume(PubSubEvent event) throws Exception {
     void consumeFromLatest(PubSubEvent event) throws Exception {
     }
 
-    ConsumeFromLatest
+    @Subscription(topic = TestTopicTopic.class, from = FromOffset.LATEST)
     @Retry(count = 2, minBackoff = "1s", maxBackoff = "1s")
     public void consumeButFailAndRetry(PubSubEvent event) {
         throw new RuntimeException("always error: event " + event.getTime());
diff --git a/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java b/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java
index bbf9685a9d..727ea56768 100644
--- a/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java
+++ b/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java
@@ -67,6 +67,8 @@ private SchemaContributorBuildItem generateSubscription(MethodInfo method, Strin
                             .setMinBackoff(retry.minBackoff());
                     builder.addMetadata(Metadata.newBuilder().setRetry(retryBuilder).build());
                 }
+
+                log.info("FromOffset value is: " + info.from());
             }));
         });
     }