conduktor.io ↗

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

AuthorKen Huang
StatusAccepted
Kafka Version4.4
JIRAKAFKA-20167
WikiView on Apache Wiki
Created2026-02-18
Last Modified2026-04-27
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.