worker

Overview ¶

Live streaming worker for the mongo-cdc-orderstats example.

Consumes Mongo CDC events delivered via Kafka (the standard Debezium → Kafka bridge in production) and applies them through the per-customer Sum monoid into the same DynamoDB table the bootstrap binary populated. With WithDedup wired up, replays-after-crash are idempotent: a record arriving twice from Kafka after a worker restart is folded into the monoid exactly once.

Locally:

# After bootstrap has populated the initial state:
docker compose up -d kafka dynamodb-local
go run ./examples/mongo-cdc-orderstats/cmd/worker