<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/admin/client.py, branch Remove-deprecated-ConnectionError</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>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>
<entry>
<title>Fix response error checking in KafkaAdminClient send_to_controller</title>
<updated>2019-01-03T21:46:47+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-11-23T18:17:59+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=2e0ada055886ad01cc193b1007d3f79717b5c9df'/>
<id>2e0ada055886ad01cc193b1007d3f79717b5c9df</id>
<content type='text'>
Previously we weren't accounting for when the response tuple also has a
`error_message` value.

Note that in Java, the error fieldname is inconsistent:
 - `CreateTopicsResponse` / `CreatePartitionsResponse` uses `topic_errors`
 - `DeleteTopicsResponse` uses `topic_error_codes`
So this updates the `CreateTopicsResponse` classes to match.

The fix is a little brittle, but should suffice for now.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Previously we weren't accounting for when the response tuple also has a
`error_message` value.

Note that in Java, the error fieldname is inconsistent:
 - `CreateTopicsResponse` / `CreatePartitionsResponse` uses `topic_errors`
 - `DeleteTopicsResponse` uses `topic_error_codes`
So this updates the `CreateTopicsResponse` classes to match.

The fix is a little brittle, but should suffice for now.
</pre>
</div>
</content>
</entry>
<entry>
<title>Bugfix: Types need identity comparison</title>
<updated>2018-12-13T10:35:00+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-12-13T10:35:00+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=7aa997f7205c116582b3d5f354cff3c7eac89ad2'/>
<id>7aa997f7205c116582b3d5f354cff3c7eac89ad2</id>
<content type='text'>
`isinstance()` won't work here, as the types require identity comparison.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
`isinstance()` won't work here, as the types require identity comparison.</pre>
</div>
</content>
</entry>
<entry>
<title>Rename KafkaAdmin to KafkaAdminClient</title>
<updated>2018-11-20T17:24:50+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-11-20T17:03:50+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=fcc800f96f14192c44b09d1d37108377dcaed245'/>
<id>fcc800f96f14192c44b09d1d37108377dcaed245</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
