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

Matthias J. Sax updated KAFKA-21149:
------------------------------------
    Fix Version/s: 4.5.0

> Speed up JoinGracePeriodDurabilityIntegrationTest
> -------------------------------------------------
>
>                 Key: KAFKA-21149
>                 URL: https://issues.apache.org/jira/browse/KAFKA-21149
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams, unit tests
>            Reporter: Chia-Ping Tsai
>            Assignee: Jheng-Sing Chen
>            Priority: Minor
>             Fix For: 4.5.0
>
>
> 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)

Reply via email to