Arpit Goyal created KAFKA-17780:
-----------------------------------
Summary: Heartbeat interval is not configured in the
heartbeatrequest manager
Key: KAFKA-17780
URL: https://issues.apache.org/jira/browse/KAFKA-17780
Project: Kafka
Issue Type: Bug
Components: consumer
Reporter: Arpit Goyal
In the AbstractHeartBeatRequestManager , I observed we are not setting the
right heartbeat request interval. Is this intentional ?
[~lianetm] [~kirktrue]
{code:java}
long retryBackoffMs = config.getLong(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG);
long retryBackoffMaxMs =
config.getLong(ConsumerConfig.RETRY_BACKOFF_MAX_MS_CONFIG);
this.heartbeatRequestState = new HeartbeatRequestState(logContext,
time, 0, retryBackoffMs,
retryBackoffMaxMs, maxPollIntervalMs);
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
