diff --git a/confluent_client/confluent/client.py b/confluent_client/confluent/client.py index cb4058ee..506dc4aa 100644 --- a/confluent_client/confluent/client.py +++ b/confluent_client/confluent/client.py @@ -154,6 +154,7 @@ class Command(object): try: self.connection.settimeout(5) self.connection.connect(sa) + self.connection.settimeout(None) except: raise self.connection.close()