<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka, branch conn_send_buffer</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>Send socket data via non-blocking IO with send buffer</title>
<updated>2019-09-29T06:57:49+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-09-29T06:57:49+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=f95e7bb6d2a02c3c0cd0f9827b39bfe508ccd638'/>
<id>f95e7bb6d2a02c3c0cd0f9827b39bfe508ccd638</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Rely on socket selector to detect completed connection attempts (#1909)</title>
<updated>2019-09-29T02:30:09+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-09-29T02:30:09+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=89bf6a6ee51e8a54f909eae4785d04e485b91198'/>
<id>89bf6a6ee51e8a54f909eae4785d04e485b91198</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Wrap consumer.poll() for KafkaConsumer iteration (#1902)</title>
<updated>2019-09-29T02:19:29+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-09-29T02:19:29+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=5d1d42429e07f4aa2959b488ea76efb6d0bafc79'/>
<id>5d1d42429e07f4aa2959b488ea76efb6d0bafc79</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix Admin Client api version checking; only test ACL integration on 0.11+</title>
<updated>2019-09-29T00:06:57+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-09-29T00:06:57+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=98ebff87a78bafbb15dd95c5174c5a1041a848ed'/>
<id>98ebff87a78bafbb15dd95c5174c5a1041a848ed</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add ACL api to KafkaAdminClient (#1833)</title>
<updated>2019-09-28T21:57:05+00:00</updated>
<author>
<name>Ulrik Johansson</name>
<email>ulrik.johansson@gmail.com</email>
</author>
<published>2019-09-28T21:57:05+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=76ad6629350f20acfd6038c1e444a89bcd255f89'/>
<id>76ad6629350f20acfd6038c1e444a89bcd255f89</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Improve connection lock handling; always use context manager (#1895)</title>
<updated>2019-09-03T15:47:10+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-09-03T15:47:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=7a69952e956412f45b1eed1e217931e3ec33f2e7'/>
<id>7a69952e956412f45b1eed1e217931e3ec33f2e7</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Reduce internal client poll timeout for consumer iterator interface (#1824)</title>
<updated>2019-08-16T18:04:10+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-08-16T18:04:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=5bc25292b8bb5b20ba2fff481fdc77b9909d0831'/>
<id>5bc25292b8bb5b20ba2fff481fdc77b9909d0831</id>
<content type='text'>
More attempts to address heartbeat timing issues in consumers, especially with the iterator interface. Here we can reduce the `client.poll` timeout to at most the retry backoff (typically 100ms) so that the consumer iterator interface doesn't block for longer than the heartbeat timeout.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
More attempts to address heartbeat timing issues in consumers, especially with the iterator interface. Here we can reduce the `client.poll` timeout to at most the retry backoff (typically 100ms) so that the consumer iterator interface doesn't block for longer than the heartbeat timeout.</pre>
</div>
</content>
</entry>
<entry>
<title>Update conn.py</title>
<updated>2019-08-16T18:00:15+00:00</updated>
<author>
<name>Cameron Boulton</name>
<email>cameronboulton@gmail.com</email>
</author>
<published>2019-08-15T23:59:08+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ace6af5e5d2ff7b900bc694065562127b4efe8dc'/>
<id>ace6af5e5d2ff7b900bc694065562127b4efe8dc</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Break FindCoordinator into request/response methods</title>
<updated>2019-07-31T18:26:43+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2019-07-31T01:35:02+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ea35fdfe1d66eb481e3406ad161a1255573dd50f'/>
<id>ea35fdfe1d66eb481e3406ad161a1255573dd50f</id>
<content type='text'>
This splits the `_find_coordinator_id()` method (which is blocking) into
request generation / response parsing methods.

The public API does not change. However, this allows power users who are
willing to deal with risk of private methods changing under their feet
to decouple generating the message futures from processing their
responses. In other words, you can use these to fire a bunch of requests
at once and delay processing the responses until all requests are fired.

This is modeled on the work done in #1845.

Additionally, I removed the code that tried to leverage the error
checking from `cluster.add_group_coordinator()`. That code had changed
in #1822, removing most of the error checking... so it no longer adds
any value, but instead merely increases complexity and coupling.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This splits the `_find_coordinator_id()` method (which is blocking) into
request generation / response parsing methods.

The public API does not change. However, this allows power users who are
willing to deal with risk of private methods changing under their feet
to decouple generating the message futures from processing their
responses. In other words, you can use these to fire a bunch of requests
at once and delay processing the responses until all requests are fired.

This is modeled on the work done in #1845.

Additionally, I removed the code that tried to leverage the error
checking from `cluster.add_group_coordinator()`. That code had changed
in #1822, removing most of the error checking... so it no longer adds
any value, but instead merely increases complexity and coupling.
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix minor typo (#1865)</title>
<updated>2019-07-14T15:22:10+00:00</updated>
<author>
<name>Carson Ip</name>
<email>carsonip@users.noreply.github.com</email>
</author>
<published>2019-07-14T15:22:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=eed25fc36110b12ec370b4d0e332173abce9076f'/>
<id>eed25fc36110b12ec370b4d0e332173abce9076f</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
