diff options
| author | Alexey Borzenkov <snaury@gmail.com> | 2014-04-03 21:39:19 +0400 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-25 10:37:37 +0300 |
| commit | bc0d5c1e275805d2b207900923ef5c87c45127d9 (patch) | |
| tree | b15a97b8701585a583c86c66a43b1183f5d991c1 /kafka/conn.py | |
| parent | 250778453fcece7316615bd62795e9293c62e525 (diff) | |
| download | kafka-python-bc0d5c1e275805d2b207900923ef5c87c45127d9.tar.gz | |
Make KafkaConnection copies usable across threads
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 30debec..8142c45 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -62,6 +62,9 @@ class KafkaConnection(local): self.reinit() + def __getnewargs__(self): + return (self.host, self.port, self.timeout) + def __repr__(self): return "<KafkaConnection host=%s port=%d>" % (self.host, self.port) @@ -167,6 +170,7 @@ class KafkaConnection(local): c.port = copy.copy(self.port) c.timeout = copy.copy(self.timeout) c._sock = None + c._dirty = True return c def close(self): |