Add backfills history; refactor record consumer state

sequinstream / sequin

Postgres CDC to streams and queues like Kafka, SQS, HTTP endpoints, and more

https://sequinstream.com

MIT License

498 stars 16 forks source link

Closed RTLS closed 5 days ago

RTLS commented 5 days ago

[X] Add backfills table
- [X] belongs to sink consumer
- [X] one active per consumer
[X] refactor consumer record state to use currently active backfill