conduktor.io ↗

KIP-459 — Improve KafkaStreams#close

Discussion StreamsConsumer

KIP-459 overhauls `KafkaStreams.close()` to accept a `CloseOptions` object that supports a configurable timeout and an optional `leaveGroup` flag controlling whether the embedded consumer leaves the consumer group during shutdown. The existing `close(Duration)` API has no way to disable consumer group leave, causing unnecessary rebalances during rolling restarts, and the timeout semantics were inconsistently applied across internal components.

Details

AuthorDongjin Lee
StatusDiscussion
JIRAKAFKA-7996
WikiView on Apache Wiki
Created2019-04-24
Last Modified2019-05-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.