Andrea Cosentino created CAMEL-26843:
----------------------------------------
Summary: 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
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)
