You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/09/23 09:50:00 UTC

[jira] [Assigned] (KAFKA-21149) Speed up JoinGracePeriodDurabilityIntegrationTest

     [ https://issues.apache.org/jira/browse/KAFKA-21149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jheng-Sing Chen reassigned KAFKA-21149:
---------------------------------------

    Assignee: Jheng-Sing Chen  (was: Chia-Ping Tsai)

> Speed up JoinGracePeriodDurabilityIntegrationTest
> -------------------------------------------------
>
>                 Key: KAFKA-21149
>                 URL: https://issues.apache.org/jira/browse/KAFKA-21149
>             Project: Kafka
>          Issue Type: Improvement
>            Reporter: Chia-Ping Tsai
>            Assignee: Jheng-Sing Chen
>            Priority: Minor
>
> It can leverage the LEAVE_GROUP to speed up the bounce in {{{}shouldRecoverBufferAfterShutdown{}}}, since the restart with the same application id waits for the previous member's session timeout otherwise.
> {code:java}
>             // restart the driver
>             driver.close(CloseOptions.groupMembershipOperation(CloseOptions.GroupMembershipOperation.LEAVE_GROUP));
>             assertEquals(KafkaStreams.State.NOT_RUNNING, driver.state()); {code}



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