diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/client.py b/kafka/client.py index 212f5c3..c25e2d2 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -73,6 +73,9 @@ class KafkaClient(object): self._sock.settimeout(10) log.debug("Connected to %s on %d", host, port) + def __copy__(self): + return KafkaClient(self.host, self.port, self.bufsize) + ###################### # Protocol Stuff # ###################### |