Event streaming

Kafka share groups swap partition ownership for a 2,000-record lock budget

KIP-932 lets a group run more consumers than a topic has partitions by locking each record for 30 seconds and counting its deliveries. The idempotence, the retries and the lock sizing become the application's job.