[
https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18045695#comment-18045695
]
Kirk True commented on KAFKA-16799:
-----------------------------------
[~devtrace404], yes {{devtrace404}} is the string I searched for.
[This wiki
page|https://cwiki.apache.org/confluence/display/KAFKA/Reporting+Issues+in+Apache+Kafka]
includes these prerequisites for Jira Assignees:
{quote}If you are a developer intending to fix the bug, put your JIRA ID in the
Assignee field (you need to be in the contributors list of Apache Kafka in
order to be assigned to a JIRA ticket; if you have not been added to the list,
send an email to the users@kafka mailing list to request for it).
{quote}
If you're not already on the users (or dev) mailing list, you'll need to sign
up for that first. See [this page|https://kafka.apache.org/contact] for
instructions to join the mailing lists.
Thanks!
> NetworkClientDelegate is not backing off if the node is not found
> -----------------------------------------------------------------
>
> Key: KAFKA-16799
> URL: https://issues.apache.org/jira/browse/KAFKA-16799
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
> Reporter: Philip Nee
> Assignee: Kirk True
> Priority: Major
> Labels: consumer-threading-refactor
>
> When performing stress testing, I found that AsycnKafkaConsumer's network
> client delegate isn't backing off if the node is not ready, causing a large
> number of:
> {code:java}
> 358 [2024-05-20 22:59:02,591] DEBUG [Consumer
> clientId=consumer.7136899e-0c20-4ccb-8ba3-497e9e683594-0,
> groupId=consumer-groups-test-5] Node is not ready, handle the request in the
> next event loop: node=b4-pkc-devcmkz697.us-west-2.aws.devel.cpd
> ev.cloud:9092 (id: 2147483643 rack: null),
> request=UnsentRequest{requestBuilder=ConsumerGroupHeartbeatRequestData(groupId='consumer-groups-test-5',
> memberId='', memberEpoch=0, instanceId=null, rackId=null,
> rebalanceTimeoutMs=100000, subscri
> bedTopicNames=[_kengine-565-test-topic8081], serverAssignor=null,
> topicPartitions=[]),
> handler=org.apache.kafka.clients.consumer.internals.NetworkClientDelegate$FutureCompletionHandler@139a8761,
> node=Optional[b4-pkc-devcmkz697.us-west-2.aws .devel.cpdev.cloud:9092
> (id: 2147483643 rack: null)],
> timer=org.apache.kafka.common.utils.Timer@649fffad}
> (org.apache.kafka.clients.consumer.internals.NetworkClientDelegate:169) {code}
> show up in the log.
> What should have happened is: 1. node is not ready 2. exponential back off 3.
> retry
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
