Description
Modern applications need to react to data changes in real-time. ApexStore has no mechanism to subscribe to data changes.
Proposed Implementation
- Add a WAL tailer that streams changes to a configurable output
- Support outputs: Kafka, RabbitMQ, WebSocket, gRPC stream
- Each change event includes: key, new_value, old_value, timestamp, operation_type (put/delete)
- Support at-least-once delivery semantics with offset tracking
- Add CDC configuration via
config.cdc section
API
apexstore-cli cdc subscribe --output kafka://localhost:9092/changes
Impact
- Enables real-time replication to other systems
- Enables event-driven architectures
- Enables cache invalidation (Redis, CDN)
- Critical for microservices ecosystems
Labels
Description
Modern applications need to react to data changes in real-time. ApexStore has no mechanism to subscribe to data changes.
Proposed Implementation
config.cdcsectionAPI
Impact
Labels