[
https://issues.apache.org/jira/browse/CAMEL-26843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on CAMEL-26843 started by Andrea Cosentino.
------------------------------------------------
> camel-openfga - add a change-log consumer with durable checkpoints
> ------------------------------------------------------------------
>
> Key: CAMEL-26843
> URL: https://issues.apache.org/jira/browse/CAMEL-26843
> Project: Camel
> Issue Type: New Feature
> Reporter: Andrea Cosentino
> Assignee: Andrea Cosentino
> Priority: Major
> Labels: authorization, camel-openfga, component-audit
>
> h2. Problem / motivation
> readChanges exists as a producer, but continuous projection routes must
> implement timer/paging/bookmark handling themselves. The endpoint currently
> rejects consumers.
> h2. Proposed scope
> Provide a scheduled readChanges consumer with an explicit durable checkpoint
> SPI/repository. Advance the cursor only after successful processing; document
> at-least-once delivery, ordering, empty tail pages and server cursor validity
> constraints.
> h2. Acceptance criteria / validation
> * Cover processing failure, restart, repeated delivery and checkpoint store
> failure.
> * Retain a tailing continuation token when the server returns the same token
> with an empty page.
> * Bound polling and shutdown; test redelivery and selected checkpoint
> granularity.
> * Add usage and configuration documentation.
> h2. References
> *
> https://github.com/apache/camel/blob/5686684cb418/components/camel-openfga/src/main/java/org/apache/camel/component/openfga/OpenFgaProducer.java#L390
> *
> https://github.com/apache/camel/blob/5686684cb418/components/camel-openfga/src/main/java/org/apache/camel/component/openfga/OpenFgaEndpoint.java#L211
> Source: read-only component audit at 5686684cb418. Recheck current main
> before implementing; historical references identify the audited code.
> _AI-generated by Codex on behalf of oscerd (JIRA: acosentino)._
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
