KIP-1284 — Introduce CloseOptions.DEFAULT for Kafka Streams
Accepted Kafka 4.4 Streams
Introduces CloseOptions.DEFAULT as an explicit enum value for KafkaStreams.close() that selects the correct shutdown behavior based on the active rebalance protocol (LEAVE_GROUP for the Streams Protocol, REMAIN_IN_GROUP for Classic). Without this, KafkaStreams.close() with no CloseOptions implicitly uses REMAIN_IN_GROUP, which is semantically wrong for the KIP-1071 Streams Protocol where dynamic membership makes remaining in the group after shutdown counterproductive.
Details
| Author | Ken Huang |
| Status | Accepted |
| Kafka Version | 4.4 |
| JIRA | KAFKA-20167 |
| Wiki | View on Apache Wiki |
| Created | 2026-02-18 |
| Last Modified | 2026-04-27 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.