KIP-1302 — Support Share Groups (Queue Semantics) in Kafka Connect Sink Connectors

Discussion ConnectConsumer

Adds a WorkerShareSinkTask to Kafka Connect so sink connectors can consume via share groups (KIP-932) instead of consumer groups, activated globally or per-connector with consumer.override.group.protocol=share, plus share-group acquisition/release/rejection metrics in sink-task-metrics. Sink task parallelism is currently hard-capped by partition count, exclusive partition ownership makes one slow task block all records behind it, and task membership changes trigger rebalance storms.

Details