[ 
https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721114#comment-17721114
 ] 

Matthias J. Sax commented on KAFKA-14981:
-----------------------------------------

Very interesting idea – given that we persist the thread-id (aka process-id) in 
the state directory on local disk, it could help. And even if we don't persist 
it (because there is no local storage), it seems no harm would be done if the 
id changes every single time.

Wondering if we would need a KIP for this. By gut feeling is no, but not sure.

> Set `group.instance.id` in streams consumer so that rebalance will not happen 
> if a instance is restarted
> --------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-14981
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14981
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Hao Li
>            Priority: Minor
>
> `group.instance.id` enables static membership so that if a consumer is 
> restarted within `session.timeout.ms`, rebalance will not be triggered and 
> originally assignment can be returned directly from broker. We can set this 
> id in Kafka streams using `threadId` so that no rebalance is trigger within 
> `session.timeout.ms`



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to