<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/client_async.py, branch fix_records</title>
<subtitle>github.com: mumrah/kafka-python.git
</subtitle>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/'/>
<entry>
<title>Do not validate api_version against known versions (#1434)</title>
<updated>2018-03-10T15:24:31+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-03-10T15:24:31+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=22e3f75e92a791b3a42cac2a87b19ec33a4ca351'/>
<id>22e3f75e92a791b3a42cac2a87b19ec33a4ca351</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add BrokerConnection.connect_blocking() (#1411)</title>
<updated>2018-03-09T19:54:06+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-03-09T19:54:06+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=1ffdd5caf7f10fb5372780cb9a5ac4a906cac342'/>
<id>1ffdd5caf7f10fb5372780cb9a5ac4a906cac342</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Check timeout type in KafkaClient constructor</title>
<updated>2018-02-21T21:30:12+00:00</updated>
<author>
<name>Andre Araujo</name>
<email>asdaraujo@gmail.com</email>
</author>
<published>2017-11-07T00:00:34+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=0f5d35fa3489fa36000c05a891d375cc30672e23'/>
<id>0f5d35fa3489fa36000c05a891d375cc30672e23</id>
<content type='text'>
If a future was passed as the only positional parameter it would
be assigned to the "timeout_ms" parameter erroneously. This mistake
would not raise any exception but would lead to odd behaviour later,
what could make it extremely difficult to troubleshoot.

Adding a type check ensures that an exception is raise earlier to
notify the user about the problem.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
If a future was passed as the only positional parameter it would
be assigned to the "timeout_ms" parameter erroneously. This mistake
would not raise any exception but would lead to odd behaviour later,
what could make it extremely difficult to troubleshoot.

Adding a type check ensures that an exception is raise earlier to
notify the user about the problem.
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix pending completion IndexError bug caused by multiple threads (#1372)</title>
<updated>2018-02-08T19:59:54+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-02-08T19:59:54+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=41aa0342f8bfa6f2ced61be7a8b0f2cd28fbb671'/>
<id>41aa0342f8bfa6f2ced61be7a8b0f2cd28fbb671</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>use absolute imports everywhere (#1362)</title>
<updated>2018-02-06T20:10:45+00:00</updated>
<author>
<name>Kevin Tindall</name>
<email>kevinkjt2000@users.noreply.github.com</email>
</author>
<published>2018-02-06T20:10:45+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6'/>
<id>9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Remove assertion with side effect (#1348)</title>
<updated>2018-01-23T17:49:18+00:00</updated>
<author>
<name>Buğra Gedik</name>
<email>bgedik@gmail.com</email>
</author>
<published>2018-01-23T17:49:18+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=bfa6e2044ad7ecef8ab042d43e2c4d47467d3949'/>
<id>bfa6e2044ad7ecef8ab042d43e2c4d47467d3949</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Read all available socket bytes (#1332)</title>
<updated>2018-01-11T01:25:33+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-01-11T01:25:33+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=a69320b8e3199fa9d7cfa3947a242e699a045c3b'/>
<id>a69320b8e3199fa9d7cfa3947a242e699a045c3b</id>
<content type='text'>
* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters</pre>
</div>
</content>
</entry>
<entry>
<title>Improve KafkaConsumer cleanup (#1339)</title>
<updated>2018-01-10T23:56:47+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-01-10T23:56:47+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=0a7492443c78d4791cfdf3d6384c02f1c7757c7b'/>
<id>0a7492443c78d4791cfdf3d6384c02f1c7757c7b</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>KAFKA-3888 Use background thread to process consumer heartbeats (#1266)</title>
<updated>2017-12-21T22:46:10+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2017-12-21T22:46:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ad024d1e897dbf16bd629fa63895bd7af4a8d959'/>
<id>ad024d1e897dbf16bd629fa63895bd7af4a8d959</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>use python standard max value (#1303)</title>
<updated>2017-12-07T21:59:58+00:00</updated>
<author>
<name>lukeWx</name>
<email>4403510+lukekingbru@users.noreply.github.com</email>
</author>
<published>2017-12-07T21:59:58+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=009290ddd5d4616d70bff93f841e773af8b22750'/>
<id>009290ddd5d4616d70bff93f841e773af8b22750</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
