Database / ValKey Interview questions
How do you use Valkey Streams for event processing?
Streams model an append-only log of time-ordered entries, each with an auto-generated or explicit ID, which makes them a natural fit for event pipelines.
XADD orders * order_id 1042 status "created" XGROUP CREATE orders workers $ XREADGROUP GROUP workers consumer1 COUNT 5 STREAMS orders > XACK orders workers 1699999999999-0
Consumer groups let multiple worker processes share the load of a single stream, with each entry delivered to exactly one consumer in the group; a pending-entries list tracks unacknowledged messages, and XCLAIM/XAUTOCLAIM can reassign entries a stalled consumer never acknowledged.
More Related questions...