confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Allow configuring request timeout on Schema Registry client

Open m-burst opened this issue 6 years ago • 1 comments

This is a feature request.

We have encountered a problem in production. Our Kafka ops were doing some maintenance of the cluster, during which a HTTP request to schema registry hung for some reason, and the whole consumer hung with it. We had to go through a lot of pain to abort the request without restarting the whole app.

Inspecting the source code, I've noticed that there is no request timeout in the CachedSchemaRegistryClient in its calls to requests. My proposal is to allow configuring the timeout and expose it as a configuration parameter in AvroProducer and AvroConsumer.

If you agree that this should be implemented, I can try to implement it myself.

Yours, Mikhail

m-burst avatar Jun 13 '19 18:06 m-burst

Any update on this? Thank you

jordaniversen avatar Oct 14 '22 15:10 jordaniversen

Fixed by https://github.com/confluentinc/confluent-kafka-python/pull/1852

rayokota avatar Dec 12 '24 16:12 rayokota