conduktor.io ↗

KIP-289 — Improve the default group id behavior in KafkaConsumer

Accepted Kafka 2.2 Consumer

Changes `KafkaConsumer` behavior so that using the default empty `group.id` raises a clear `InvalidGroupIdException` at construction time when subscribe-based APIs are used, rather than at the first `poll()` call with a confusing error. The inconsistency between `subscribe` (which fails at poll) and `assign` (which works fine without a group.id) causes unexpected runtime failures for users who omit `group.id`.

Protocol Impact

JoinGroup

Details

AuthorVahid Hashemian
StatusAccepted
Kafka Version2.2
JIRAKAFKA-6774
WikiView on Apache Wiki
Created2018-04-27
Last Modified2018-08-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.