From 15d73f75a8d792e783ba579acc39b08fcaca5a7b Mon Sep 17 00:00:00 2001 From: Matt Toohey Date: Mon, 16 Dec 2024 11:09:42 +1100 Subject: [PATCH] =?UTF-8?q?add=20debug=20log=E2=80=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/xyz/block/ftl/java/test/subscriber/Subscriber.java | 2 +- .../java/xyz/block/ftl/deployment/SubscriptionProcessor.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) 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()); })); }); }