diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kafka/client.py b/kafka/client.py index 63c9073..20e20f2 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -254,8 +254,11 @@ class KafkaClient(object): def copy(self): """ - Create an inactive copy of the client object - A reinit() has to be done on the copy before it can be used again + Create an inactive copy of the client object, suitable for passing + to a separate thread. + + Note that the copied connections are not initialized, so reinit() must + be called on the returned copy. """ c = copy.deepcopy(self) for key in c.conns: |