| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| |
|
|
|
|
|
| |
It's just collecting dust and throwing off the coverage report.
I pushed a branch queue-fixup in case someone wants to take a stab at
refactoring it.
|
| | |
|
| |
|
|
|
|
|
| |
When running on Linux with code on a case-insensitive file system,
imports of the `Queue` module fail because python resolves the
wrong file (It is trying to use a relative import of `queue.py` in
the kafka directory). This change forces absolute imports via PEP328.
|
| | |
|
| |
|
|
| |
Also move the exceptions to common instead of util
|
| |
|
|
| |
consumer.py and conn.py will be done later after pending merges
|
| |
|
|
| |
Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
|
| |
|
|
| |
Also more docs
|
| |
|
|
| |
Ref #8
|
|
|
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
|
