Hello Matthias,

Thanks for your feedback, I have updated the table.

Best Regards,
Jiunn-Yang

> Matthias J. Sax <[email protected]> 於 2026年3月4日 清晨7:07 寫道:
> 
> Thanks for the KIP. Overall LGTM.
> 
> Can we add a column to the Behavior Matrix for "Classic/static" case?
> 
> It might also be useful, to show "existing" vs "new" behavior to make it 
> easier to compare? Maybe change the rows to:
> 
> - close() [current] -> same as close(REMAIN)
> - close() [new] -> same as close(DEFAULT)
> - close(REMAIN) [current]
> - close(REMAIN) [new]
> - close(LEAVE) [current]
> - close(LEAVE) [new]
> 
> And we could use cell background colors to highlight the change for "streams" 
> protocol and REMAIN case?
> 
> 
> -Matthias
> 
> 
> 
> On 3/2/26 6:12 AM, 黃竣陽 wrote:
>> Hello Sanghyeok An,
>> Thanks for the feedback,
>> The consumer already has corresponding close semantics that differentiate 
>> behavior
>> based on membership, and in that context I agree that having static members 
>> remain in the group
>> by default is reasonable and consistent with the goal of static membership.
>> Based on this, I plan to make the behavior explicit in the KIP: under the 
>> Streams Protocol,
>> CloseOptions.DEFAULT will resolve to remain in group for static members, 
>> while keeping
>> the existing behavior for dynamic members.
>> Best Regards,
>> Jiunn-Yang
>>> Sanghyeok An <[email protected]> 於 2026年2月27日 晚上10:57 寫道:
>>> 
>>> Hi Jiunn-Yang,
>>> Thanks for the this KIP.
>>> 
>>> I have a small question.
>>> 
>>> ash01 :
>>> Would it be worth considering mapping CloseOptions.DEFAULT differently not 
>>> only based on the protocol, but also on whether the member is static?
>>> 
>>> I recently worked on a server-side implementation of static membership for 
>>> KIP-1071.
>>> Once static members are supported under the Streams Protocol, DEFAULT close 
>>> semantics may reasonably differ between dynamic and static members.
>>> 
>>> For dynamic members, I agree with the KIP rationale that remaining in the 
>>> group provides no real benefit, so having DEFAULT map to a leave behavior 
>>> under the Streams Protocol makes sense.
>>> However, for static members, making leave the default would weaken the 
>>> primary benefit of static membership, minimizing rebalances on restart.
>>> 
>>> Would it make sense to resolve DEFAULT under the Streams Protocol as 
>>> follows?
>>> - dynamic member: DEFAULT maps to consumer CloseOptions.DEFAULT (leave)
>>> - static member: DEFAULT maps to consumer CloseOptions.REMAIN_IN_GROUP 
>>> (remain)
>>> 
>>> This would keep the no-arg KafkaStreams.close() as a safer default in both 
>>> cases, while still reserving REMAIN_IN_GROUP as an explicit user intent.
>>> Curious what you think, and whether this should be in scope for this KIP or 
>>> tracked as a follow-up.
>>> 
>>> Thanks for reading this!
>>> 
>>> Best Regards
>>> Sanghyeok An
>>> 
>>> -----Original Message-----
>>> From: "Lucas Brutschy via dev"<[email protected]>
>>> To: <[email protected]>;
>>> Cc: "Lucas Brutschy"<[email protected]>;
>>> Sent: 2026-02-24 (화) 21:26:47 (GMT+09:00)
>>> Subject: Re: [DISCUSS] KIP-1284 Introduce CloseOptions.DEFAULT for Kafka 
>>> Streams
>>> 
>>> Hi Jiunn-Yang,
>>> 
>>> Thanks for the update; it looks good to me.
>>> 
>>> Cheers,
>>> Lucas
>>> 
>>> On Tue, Feb 24, 2026 at 12:33 PM 黃竣陽 <[email protected]> wrote:
>>>> 
>>>> Hi Lucas,
>>>> 
>>>> Thanks for your feedback, I have updated the KIP.
>>>> 
>>>> Best Regards,
>>>> Jiunn-Yang
>>>> 
>>>>> Lucas Brutschy via dev <[email protected]> 於 2026年2月23日 晚上11:00 寫道:
>>>>> 
>>>>> Hi Jiunn-Yang,
>>>>> 
>>>>> Thanks for the KIP! I think it's correct and pretty much reflects what
>>>>> was written in the ticket.
>>>>> 
>>>>> One thing to point out explicitly is that there _is_ a behavioral
>>>>> change. People using REMAIN_IN_GROUP explicitly now with streams
>>>>> groups, the member left before theis KIP and will remain with this
>>>>> KIP. However, I think this is rarely used because it explicitly states
>>>>> the (old) default. Specifically with KIP-1071, I don't think many
>>>>> people will use it. I consider the behavioral change here more a bug
>>>>> fix that we are implementing as part of this KIP,  but I would still
>>>>> point it out in the KIP.
>>>>> 
>>>>> Thanks,
>>>>> Lucas
>>>>> 
>>>>> 
>>>>> 
>>>>> On Mon, Feb 23, 2026 at 2:32 PM 黃竣陽 <[email protected]> wrote:
>>>>>> 
>>>>>> Hello everyone,
>>>>>> 
>>>>>> I would like to start a discussion on KIP-1284 Introduce 
>>>>>> CloseOptions.DEFAULT for Kafka Streams
>>>>>> <https://cwiki.apache.org/confluence/x/1ow8G>
>>>>>> 
>>>>>> This proposal aims to introduce CloseOptions.DEFAULT to resolve semantic 
>>>>>> inconsistency
>>>>>> in KafkaStreams shutdown behavior across protocols.
>>>>>> 
>>>>>> Best regards,
>>>>>> Jiunn-Yang
>>>> 
> 

Reply via email to