<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/test, branch v0.9.5</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>Use producer.stop() to flush messages in async producer test</title>
<updated>2015-12-05T11:36:12+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@rd.io</email>
</author>
<published>2015-12-05T11:36: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=b687b4c5d4788d64efe9b7bcfb776e57d6fbcc8e'/>
<id>b687b4c5d4788d64efe9b7bcfb776e57d6fbcc8e</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Cleanup new producer tests...</title>
<updated>2015-12-05T01:15:49+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@rd.io</email>
</author>
<published>2015-12-05T01:15:49+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=fb024355f07735d148c035dfd51b279d1b8e59df'/>
<id>fb024355f07735d148c035dfd51b279d1b8e59df</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>new pylint disables for pylint 1.5.1</title>
<updated>2015-12-03T01:43:15+00:00</updated>
<author>
<name>Zack Dever</name>
<email>zack.dever@rd.io</email>
</author>
<published>2015-12-03T00:23:01+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=16f61547787e9cb5be855ec1c4391b3b56765ab8'/>
<id>16f61547787e9cb5be855ec1c4391b3b56765ab8</id>
<content type='text'>
tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should
pass travis builds.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should
pass travis builds.
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #420 from toddpalino/master</title>
<updated>2015-12-02T23:50:05+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T23:50:05+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=3e28b42e6691b864b6f940034a4ccdce0b69d406'/>
<id>3e28b42e6691b864b6f940034a4ccdce0b69d406</id>
<content type='text'>
Initial support for consumer coordinator</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Initial support for consumer coordinator</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests</title>
<updated>2015-12-02T22:21:13+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T22:21:13+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=58e2ab41a76518c433d7375a24191018b85ced85'/>
<id>58e2ab41a76518c433d7375a24191018b85ced85</id>
<content type='text'>
Use unblocking io for broker aware requests</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Use unblocking io for broker aware requests</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #457 from saaros/block-for-number-of-messages</title>
<updated>2015-12-02T21:50:22+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T21:50:22+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=2eca5538eef948ef3828be5c3cb5c78c1c958f6f'/>
<id>2eca5538eef948ef3828be5c3cb5c78c1c958f6f</id>
<content type='text'>
Consumers get_messages: allow blocking until some messages are received</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Consumers get_messages: allow blocking until some messages are received</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #439 from chrischamberlin/fix-murmur</title>
<updated>2015-12-02T21:34:33+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T21:34:33+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=4fc15a5f27ff6f4c0c96ba39b55521891e96e5d5'/>
<id>4fc15a5f27ff6f4c0c96ba39b55521891e96e5d5</id>
<content type='text'>
Fix translation of Java murmur2 code, fix byte encoding for Python 3.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Fix translation of Java murmur2 code, fix byte encoding for Python 3.</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #435 from docker-hub/fix-producer-cleanup-logic</title>
<updated>2015-12-02T21:33:30+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T21:33: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=149d43cf6cfe121347c15b39600299b29b583dc1'/>
<id>149d43cf6cfe121347c15b39600299b29b583dc1</id>
<content type='text'>
Reworked the if statement logic to only call stop() on not-stopped producer objects</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Reworked the if statement logic to only call stop() on not-stopped producer objects</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #409 from scrapinghub/feature-allow-null-payload</title>
<updated>2015-12-02T20:49:49+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2015-12-02T20:49:49+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=0d41e6b07ea16b1074d3a63d521747361f1c7145'/>
<id>0d41e6b07ea16b1074d3a63d521747361f1c7145</id>
<content type='text'>
Allow null payload for deletion feature</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Allow null payload for deletion feature</pre>
</div>
</content>
</entry>
<entry>
<title>Add tests. Bug fix. Rename socket_conn dict.</title>
<updated>2015-11-11T01:58:04+00:00</updated>
<author>
<name>Enrico Canzonieri</name>
<email>ecanzonieri@gmail.com</email>
</author>
<published>2015-10-24T23:50:46+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=c2adeeab057b825c8cccae67aac822be02293211'/>
<id>c2adeeab057b825c8cccae67aac822be02293211</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
