[
https://issues.apache.org/jira/browse/KAFKA-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sankalp Bhatia updated KAFKA-15565:
-----------------------------------
Description:
It seems to me there is a bug in this line in the KafkaAdminClient. For the
constructor arg defaultRequestTimeoutMs of NetworkClient [1], it uses a
hardcoded value of 1 hour. Ideally, this should be derived from the client
config /** <code>request.timeout.ms</code> */ from the
AdminClientConfig[2].
References
[1][https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java#L521]
[2][https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java#L98]
was:
It seems to me there is a bug in this line in the KafkaAdminClient. For the
constructor arg defaultRequestTimeoutMs of NetworkClient [1], it uses a
hardcoded value of 1 hour. Ideally, this should be derived from the client
config /** <code>request.timeout.ms</code> */ from the
AdminClientConfig[2].
References
[1][https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java#L521]
[2]https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java#L98
> KafkaAdminClient does not honor request timeout ms
> ---------------------------------------------------
>
> Key: KAFKA-15565
> URL: https://issues.apache.org/jira/browse/KAFKA-15565
> Project: Kafka
> Issue Type: Bug
> Reporter: Sankalp Bhatia
> Assignee: Sankalp Bhatia
> Priority: Minor
>
> It seems to me there is a bug in this line in the KafkaAdminClient. For the
> constructor arg defaultRequestTimeoutMs of NetworkClient [1], it uses a
> hardcoded value of 1 hour. Ideally, this should be derived from the client
> config /** <code>request.timeout.ms</code> */ from the
> AdminClientConfig[2].
> References
> [1][https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java#L521]
> [2][https://github.com/apache/kafka/blob/1c3eb4395a15cf4f45b6dc0d39effb3dc087f5a4/clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java#L98]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
