This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-examples.git
The following commit(s) were added to refs/heads/main by this push: new 70b65e27 (chores) Fix resume-related method that was renamed on core 70b65e27 is described below commit 70b65e279c46bead489a6996eadfd9680b9eea59 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Wed Jun 8 15:51:43 2022 +0200 (chores) Fix resume-related method that was renamed on core --- .../example/resume/strategies/kafka/file/LargeFileRouteBuilder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file/LargeFileRouteBuilder.java b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file/LargeFileRouteBuilder.java index e304620e..63b20fc1 100644 --- a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file/LargeFileRouteBuilder.java +++ b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file/LargeFileRouteBuilder.java @@ -65,7 +65,7 @@ public class LargeFileRouteBuilder extends RouteBuilder { FileOffset offsetContainer = cache.get(path, FileOffset.class); if (offsetContainer != null) { - lastOffset = offsetContainer.offset(); + lastOffset = offsetContainer.getValue(); } else { lastOffset = 0; }