Add a Queue-like producer/consumer

Creates a producer process and one consumer process per partition. Uses
`multiprocessing.Queue` for communication between the parent process and
the producer/consumers.

```python
kafka = KafkaClient("localhost", 9092)
q = KafkaQueue(kafka, client="test-queue", partitions=[0,1])
q.put("test")
q.get()
q.close()
kafka.close()
```

Ref #8

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   #
     ######################