<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/test, branch v0.8.0</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>Auto-adjusting consumer fetch size</title>
<updated>2013-09-09T04:47:28+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2013-09-09T04:44:36+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=f67ad27f72aca077f24fa801a9d2d3075d6d5b60'/>
<id>f67ad27f72aca077f24fa801a9d2d3075d6d5b60</id>
<content type='text'>
Related to #42

Adds new ConsumerFetchSizeTooSmall exception that is thrown when
`_decode_message_set_iter` gets a BufferUnderflowError but has not yet
yielded a message

In this event, SimpleConsumer will increase the fetch size by 1.5 and
continue the fetching loop while _not_ increasing the offset (basically
just retries the request with a larger fetch size)

Once the consumer fetch size has been increased, it will remain
increased while SimpleConsumer fetches from that partition
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Related to #42

Adds new ConsumerFetchSizeTooSmall exception that is thrown when
`_decode_message_set_iter` gets a BufferUnderflowError but has not yet
yielded a message

In this event, SimpleConsumer will increase the fetch size by 1.5 and
continue the fetching loop while _not_ increasing the offset (basically
just retries the request with a larger fetch size)

Once the consumer fetch size has been increased, it will remain
increased while SimpleConsumer fetches from that partition
</pre>
</div>
</content>
</entry>
<entry>
<title>Fixed #42, make fetch size configurable</title>
<updated>2013-09-09T00:20:12+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2013-09-09T00:20: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=40d8e9e550b48755e2f40cfd0877a5b848a3254f'/>
<id>40d8e9e550b48755e2f40cfd0877a5b848a3254f</id>
<content type='text'>
Was hard coded to 1024 bytes which meant that larger messages were
unconsumable since they would always get split causing the consumer to
stop.

It would probably be best to automatically retry truncated messages with
a larger request size so you don't have to know your max message size
ahead of time
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Was hard coded to 1024 bytes which meant that larger messages were
unconsumable since they would always get split causing the consumer to
stop.

It would probably be best to automatically retry truncated messages with
a larger request size so you don't have to know your max message size
ahead of time
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge branch 'issue-35'</title>
<updated>2013-07-26T12:39:44+00:00</updated>
<author>
<name>David Arthur</name>
<email>mumrah@gmail.com</email>
</author>
<published>2013-07-26T12:39:44+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=e297a7a8c8f9de341b0e91346236455d12ae7f82'/>
<id>e297a7a8c8f9de341b0e91346236455d12ae7f82</id>
<content type='text'>
Conflicts:
	kafka/__init__.py
	kafka/consumer.py
	test/test_integration.py
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Conflicts:
	kafka/__init__.py
	kafka/consumer.py
	test/test_integration.py
</pre>
</div>
</content>
</entry>
<entry>
<title>Test cases for multi-process consumer and blocking APIs</title>
<updated>2013-06-27T12:17:47+00:00</updated>
<author>
<name>Mahendra M</name>
<email>mahendra.m@gmail.com</email>
</author>
<published>2013-06-27T12:17:47+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=36b5f8154304a7fef437795250885230dff835b1'/>
<id>36b5f8154304a7fef437795250885230dff835b1</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Test cases for new producer</title>
<updated>2013-06-27T08:32:45+00:00</updated>
<author>
<name>Mahendra M</name>
<email>mahendra.m@gmail.com</email>
</author>
<published>2013-06-27T08:32:45+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=d2df8f54637490b1dbe858066b74710b57186016'/>
<id>d2df8f54637490b1dbe858066b74710b57186016</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Use 127.0.0.1 instead of localhost</title>
<updated>2013-06-08T01:20:55+00:00</updated>
<author>
<name>Ivan Pouzyrevsky</name>
<email>sandello@yandex-team.ru</email>
</author>
<published>2013-06-02T10:25:58+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=499038118b2dde4ed634b2084b2d0693229a7c25'/>
<id>499038118b2dde4ed634b2084b2d0693229a7c25</id>
<content type='text'>
This alleviates IPv4 -vs- IPv6 issues in ZK and Kafka.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This alleviates IPv4 -vs- IPv6 issues in ZK and Kafka.
</pre>
</div>
</content>
</entry>
<entry>
<title>toxify all the tests and use xfail marks</title>
<updated>2013-06-08T01:20:55+00:00</updated>
<author>
<name>Ivan Pouzyrevsky</name>
<email>sandello@yandex-team.ru</email>
</author>
<published>2013-06-02T08:31:42+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=60200c671b83838159f5b9b2ee9c4c5cbac0ec14'/>
<id>60200c671b83838159f5b9b2ee9c4c5cbac0ec14</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Split fixtures out to a separate file</title>
<updated>2013-06-08T01:20:55+00:00</updated>
<author>
<name>Ivan Pouzyrevsky</name>
<email>sandello@yandex-team.ru</email>
</author>
<published>2013-06-02T08:29:25+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=2bd2dbcc9b141b76a91e6a4d92110e6ecc8bb3df'/>
<id>2bd2dbcc9b141b76a91e6a4d92110e6ecc8bb3df</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Adhere to common python naming conventions</title>
<updated>2013-06-08T01:20:55+00:00</updated>
<author>
<name>Ivan Pouzyrevsky</name>
<email>sandello@yandex-team.ru</email>
</author>
<published>2013-06-01T21:32:26+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=f444caaee77f0cb61148f4e7b05670bc19729f3e'/>
<id>f444caaee77f0cb61148f4e7b05670bc19729f3e</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Refactor and update integration tests</title>
<updated>2013-06-08T01:20:55+00:00</updated>
<author>
<name>Ivan Pouzyrevsky</name>
<email>sandello@yandex-team.ru</email>
</author>
<published>2013-06-01T21:26:14+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74'/>
<id>e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
