diff options
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 30debec..ea55481 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) |