[jira] (KAFKA-16190) Member should send full heartbeat when rejoining

["Quoc Phong Dang (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-16190 ]


    Quoc Phong Dang deleted comment on KAFKA-16190:
    -----------------------------------------

was (Author: JIRAUSER303789):
[~kirktrue] Thank you and sorry for the dely, It takes my sometime to look into the KIP and trying to navigate the code. I'm trying to see how should i know if a consumer is rejoin.

> Member should send full heartbeat when rejoining
> ------------------------------------------------
>
>                 Key: KAFKA-16190
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16190
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: clients, consumer
>            Reporter: Lianet Magrans
>            Assignee: Quoc Phong Dang
>            Priority: Critical
>              Labels: client-transitions-issues, kip-848-client-support, newbie
>             Fix For: 3.8.0
>
>
> The heartbeat request builder should make sure that all fields are sent in the heartbeat request when the consumer rejoins (currently the HeartbeatRequestManager request builder is reset on failure scenarios, which should cover the fence+rejoin sequence). 
> Note that the existing HeartbeatRequestManagerTest.testHeartbeatState misses this exact case given that it does explicitly change the subscription when it gets fenced. We should ensure we test a consumer that keeps it same initial subscription when it rejoins after being fenced.



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