add debug log…

block · Dec 16, 2024 · 15d73f7 · 15d73f7
1 parent d19901b
commit 15d73f7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java b/...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/...ntime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java b/...ntime/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());
             }));
         });
     }
-Original file line number
+Diff line change
@@ Expand Up @@
                                 .setMinBackoff(retry.minBackoff());
                         builder.addMetadata(Metadata.newBuilder().setRetry(retryBuilder).build());
                     }
+                    log.info("FromOffset value is: " + info.from());
                 }));
             });
         }
@@ Expand Down @@