worker

Overview ¶

Streaming worker binary for the recently-interacted-topk example.

Reads interaction events from a Kafka topic (typically internal application events) and folds them into the shared TopK sketch in DynamoDB. Pair with the cmd/lambda binary that consumes a Kinesis stream — both binaries write to the same DDB row, so the merged TopK reflects interactions from BOTH channels.

In production this binary runs as an ECS Fargate service. Locally:

docker compose up -d kafka dynamodb-local
export KAFKA_BROKERS=localhost:9092
export KAFKA_TOPIC=interactions
export DDB_ENDPOINT=http://localhost:8000
go run ./examples/recently-interacted-topk/cmd/worker