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
| Author | Dongjin Lee |
| Status | Discussion |
| JIRA | KAFKA-7996 |
| Wiki | View on Apache Wiki |
| Created | 2019-04-24 |
| Last Modified | 2019-05-30 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.