<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/test, branch 0.7</title>
<subtitle>github.com: mumrah/kafka-python.git
</subtitle>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/'/>
<entry>
<title>Add some docs and KafkaQueue config</title>
<updated>2012-11-20T01:47:27+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-11-19T16:42:09+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=1d0bc784d41364d6178dce452f2ac787b52749a8'/>
<id>1d0bc784d41364d6178dce452f2ac787b52749a8</id>
<content type='text'>
Ref #8
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Ref #8
</pre>
</div>
</content>
</entry>
<entry>
<title>Add a Queue-like producer/consumer</title>
<updated>2012-11-20T01:47:27+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-11-19T15:29:30+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=330ddbca4464f32d31b662eb95b92113e7024323'/>
<id>330ddbca4464f32d31b662eb95b92113e7024323</id>
<content type='text'>
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
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
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
</pre>
</div>
</content>
</entry>
<entry>
<title>Add Snappy support</title>
<updated>2012-11-16T20:02:49+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-11-16T20:02:12+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=26414d4a993b6d0fd9074b2e7c4abc4230ae52eb'/>
<id>26414d4a993b6d0fd9074b2e7c4abc4230ae52eb</id>
<content type='text'>
Fixes #2
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Fixes #2
</pre>
</div>
</content>
</entry>
<entry>
<title>Integration test writes to a file instead of stdout</title>
<updated>2012-10-30T14:41:13+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-30T14:40:41+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=8ca656d3809b14c33ae0838e656433c4b12b3313'/>
<id>8ca656d3809b14c33ae0838e656433c4b12b3313</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Adding a test for 10k messages</title>
<updated>2012-10-30T14:41:13+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-30T14:21:21+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=061b4c558ecb4f2a4f52180b1b2df2ab39fabada'/>
<id>061b4c558ecb4f2a4f52180b1b2df2ab39fabada</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Isn't it nice when tests actually find bugs</title>
<updated>2012-10-03T00:26:12+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-03T00:26:12+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=d9aafb14c24e92a114a5e5a6c2de284e22d6e01b'/>
<id>d9aafb14c24e92a114a5e5a6c2de284e22d6e01b</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Packaging improvments</title>
<updated>2012-10-02T17:19:23+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-02T17:16:16+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=cab6fee1e76fa133898e9c9570da6d432066d1c3'/>
<id>cab6fee1e76fa133898e9c9570da6d432066d1c3</id>
<content type='text'>
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)
```
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
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)
```
</pre>
</div>
</content>
</entry>
<entry>
<title>Renaming kafka.py to client.py</title>
<updated>2012-10-02T16:20:57+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-02T16:20:57+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=c448bf367036d3a3c04ee553987da6be64820d00'/>
<id>c448bf367036d3a3c04ee553987da6be64820d00</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Moved codec stuff into it's own module</title>
<updated>2012-10-02T16:14:48+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-02T16:14:48+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=c99d4119f2d6d0fdee38a159e1c845e42cf398b1'/>
<id>c99d4119f2d6d0fdee38a159e1c845e42cf398b1</id>
<content type='text'>
Snappy will go there when I get around to it
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Snappy will go there when I get around to it
</pre>
</div>
</content>
</entry>
<entry>
<title>Start work on packaging issue #3</title>
<updated>2012-10-02T16:09:19+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2012-10-02T16:09:19+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=36b67b79202f8bdeab60de1f4ed582328eeb04db'/>
<id>36b67b79202f8bdeab60de1f4ed582328eeb04db</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
