<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/admin, 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>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>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>Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient`</title>
<updated>2019-06-28T19:41:46+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2019-06-28T19:34:03+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=279a7dd85d5d15f8fffde95e0a2425cb8a2d4fe3'/>
<id>279a7dd85d5d15f8fffde95e0a2425cb8a2d4fe3</id>
<content type='text'>
Previously the `sasl_kerberos_domain_name` was missing from the Admin
client. It is already present in the Consumer/Producer, and in all three
cases gets transparently passed down to the client.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Previously the `sasl_kerberos_domain_name` was missing from the Admin
client. It is already present in the Consumer/Producer, and in all three
cases gets transparently passed down to the client.
</pre>
</div>
</content>
</entry>
<entry>
<title>Update KafkaAdminClient Docs</title>
<updated>2019-06-21T18:59:24+00:00</updated>
<author>
<name>Rob Cardy</name>
<email>rob.cardy@shopify.com</email>
</author>
<published>2019-06-21T18:15:04+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=5a72a62078b681fdfae780957bd65c66f5c2ff6d'/>
<id>5a72a62078b681fdfae780957bd65c66f5c2ff6d</id>
<content type='text'>
Updated to include SASL_PLAINTEXT and SASL_SSL as options for security_protocol.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Updated to include SASL_PLAINTEXT and SASL_SSL as options for security_protocol.</pre>
</div>
</content>
</entry>
<entry>
<title>Break consumer operations into request / response methods (#1845)</title>
<updated>2019-06-20T01:17:25+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2019-06-20T01:17:25+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=01053daac9fa18d5497a42fb58a5a3aa8add116f'/>
<id>01053daac9fa18d5497a42fb58a5a3aa8add116f</id>
<content type='text'>
This breaks some of the consumer operations 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 request
at once and delay processing the responses until all requests are fired.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This breaks some of the consumer operations 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 request
at once and delay processing the responses until all requests are fired.</pre>
</div>
</content>
</entry>
<entry>
<title>Use futures to parallelize calls to _send_request_to_node() (#1807)</title>
<updated>2019-05-21T20:33:30+00:00</updated>
<author>
<name>Lou-Cipher</name>
<email>dmheitman@gmail.com</email>
</author>
<published>2019-05-21T20:33:30+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=f145e37c1992da71d5c65c0d86ae971cda62e058'/>
<id>f145e37c1992da71d5c65c0d86ae971cda62e058</id>
<content type='text'>
Use `futures` to parallelize calls to `_send_request_to_node()`

This allows queries that need to go to multiple brokers to be run in parallel.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Use `futures` to parallelize calls to `_send_request_to_node()`

This allows queries that need to go to multiple brokers to be run in parallel.</pre>
</div>
</content>
</entry>
<entry>
<title>Update sasl configuration docstrings</title>
<updated>2019-03-24T01:01:18+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-03-24T01:01:18+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f'/>
<id>ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Support SASL OAuthBearer Authentication (#1750)</title>
<updated>2019-03-23T01:24:29+00:00</updated>
<author>
<name>Phong Pham</name>
<email>pt2pham@users.noreply.github.com</email>
</author>
<published>2019-03-23T01:24:29+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2'/>
<id>8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix `AttributeError` caused by `getattr()`</title>
<updated>2019-01-07T20:57:25+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2019-01-07T20:57:25+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=1a31be52ec012dfa0ef5079ff9982e01408a8fe1'/>
<id>1a31be52ec012dfa0ef5079ff9982e01408a8fe1</id>
<content type='text'>
`getattr(object, 'x', object.y)` will evaluate the default argument
`object.y` regardless of whether `'x'` exists.

For details see: https://stackoverflow.com/q/31443989/770425
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
`getattr(object, 'x', object.y)` will evaluate the default argument
`object.y` regardless of whether `'x'` exists.

For details see: https://stackoverflow.com/q/31443989/770425
</pre>
</div>
</content>
</entry>
</feed>
