[
https://issues.apache.org/jira/browse/KAFKA-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-16536:
-----------------------------------------------
Description:
Change the leader's implementation of the BeginQuorumEpoch to behave more like
a heartbeat mechanism. The first implementation can just send the request at
some interval (half the fetch timeout).
Future implementations can conserve resource by tracking fetch timeouts per
remote voter.
This change is needed because voters discover the leader and the leader's
endpoints through the BeginQuorumEpoch RPC. The leader id is persisted in
quorum-state but the leader's endpoints are not persisted to disk. That means
that if the voter restarts it needs to rediscover the leader through the
BeginQuorumEpoch RPC.
was:
Change the leader's implementation of the BeginQuorumEpoch to behave more like
a heartbeat mechanism. The first implementation can just send the request at
some interval (half the fetch timeout).
Future implementations can conserve resource by tracking fetch timeouts per
remote voter.
> Use BeginQuorumEpoch as the leader's heartbeat
> ----------------------------------------------
>
> Key: KAFKA-16536
> URL: https://issues.apache.org/jira/browse/KAFKA-16536
> Project: Kafka
> Issue Type: Sub-task
> Components: kraft
> Reporter: José Armando García Sancio
> Assignee: Alyssa Huang
> Priority: Major
>
> Change the leader's implementation of the BeginQuorumEpoch to behave more
> like a heartbeat mechanism. The first implementation can just send the
> request at some interval (half the fetch timeout).
> Future implementations can conserve resource by tracking fetch timeouts per
> remote voter.
> This change is needed because voters discover the leader and the leader's
> endpoints through the BeginQuorumEpoch RPC. The leader id is persisted in
> quorum-state but the leader's endpoints are not persisted to disk. That means
> that if the voter restarts it needs to rediscover the leader through the
> BeginQuorumEpoch RPC.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
