delta/python-packages/kafka-python.git/kafka, branch 0.7

Adding client_fetch_size to queue interface

2013-04-03T00:19:29+00:00

Also more docs

Add some docs and KafkaQueue config

2012-11-20T01:47:27+00:00

Ref #8

Add a Queue-like producer/consumer

2012-11-20T01:47:27+00:00

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

Add Snappy support

2012-11-16T20:02:49+00:00

Fixes #2

Clean up imports in client, fixed #5

2012-10-30T14:41:13+00:00

Replace socket.send with socket.sendall, Fixes #6

2012-10-30T14:41:13+00:00

error handling fix

2012-10-25T17:32:13+00:00

Isn't it nice when tests actually find bugs

2012-10-03T00:26:12+00:00

Packaging improvments

2012-10-02T17:19:23+00:00

Can now:

```python
import kafka
kafka.KafkaClient("localhost", 9092)
```

or

```python
from kafka.client import KafkaClient
KafkaClient("localhost", 9092)
```

or

```python
import kafka.client
kafka.client.KafkaClient("localhost", 9092)
```

Renaming kafka.py to client.py

2012-10-02T16:20:57+00:00