Schemaregistrytimeoutoption

confluent_kafka/schema_registry/schema_registry_client.py

@@ -95,7 +95,7 @@ def __init__(self, conf):
             raise ValueError("ssl.certificate.location required when"
                              " configuring ssl.key.location")
 
-        self.timeout = conf_copy.pop('timeout', 30.00)
+        self.timeout = conf_copy.pop('request.timeout', 30.00)
 
         userinfo = utils.get_auth_from_url(base_url)
         if 'basic.auth.user.info' in conf_copy:
@@ -282,7 +282,12 @@ class SchemaRegistryClient(object):
     |                              |      | By default userinfo is extracted from           |
     |                              |      | the URL if present.                             |
     +------------------------------+------+-------------------------------------------------+
-
+    |                              |      | Timeout for HTTP/S calls to Schema registry     |
+    |                              |      |                                                 |
+    | ``request.timeout``          |float |                                                 |
+    |                              |      | By default timeout is 30.00 seconds             |
+    |                              |      | the URL if present.                             |
+    +------------------------------+------+-------------------------------------------------+
     Args:
         conf (dict): Schema Registry client configuration.
 

tests/schema_registry/test_api_client.py

@@ -21,6 +21,7 @@
 
 from confluent_kafka.schema_registry.error import SchemaRegistryError
 from confluent_kafka.schema_registry.schema_registry_client import Schema
+from urllib3.exceptions import ConnectTimeoutError
 
 """
     Basic SchemaRegistryClient API functionality tests.
@@ -376,3 +377,13 @@ def test_schema_equivilence(load_avsc):
     assert schema == schema2
     assert schema_str1.__eq__(schema_str2)
     assert schema_str1 == schema_str2
+
+def test_timeout_exception_thrown_when_unreasonably_low_timeout_set(mock_schema_registry):
+    conf = {'url': TEST_URL,
+        'request.timeout' : 0.01   
+    }
+    sr = mock_schema_registry(conf)
+    with pytest.raises(ConnectTimeoutError) as e :
+       sr.get_schema()
+    assert isinstance(e, ConnectTimeoutError)
+