<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/admin, branch 2.0.2</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>Merge _find_coordinator_id methods (#2127)</title>
<updated>2020-09-17T19:15:08+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2020-09-17T19:15:08+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=098ecbfd79ce8919c1d3dec50a207bbbe62c894c'/>
<id>098ecbfd79ce8919c1d3dec50a207bbbe62c894c</id>
<content type='text'>
Previously there were two methods:
* `_find_coordinator_id()`
* `_find_many_coordinator_ids()`

But they do basically the same thing internally. And we need the plural
two places, but the singular only one place.

So merge them, and change the function signature to take a list of
`group_ids` and return a dict of `group_id: coordinator_id`s.

As a result of this, the `describe_groups()` command should scale better
because the `_find_coordinator_ids()` command issues all the requests
async, instead of sequentially blocking as the `described_groups()` used
to do.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Previously there were two methods:
* `_find_coordinator_id()`
* `_find_many_coordinator_ids()`

But they do basically the same thing internally. And we need the plural
two places, but the singular only one place.

So merge them, and change the function signature to take a list of
`group_ids` and return a dict of `group_id: coordinator_id`s.

As a result of this, the `describe_groups()` command should scale better
because the `_find_coordinator_ids()` command issues all the requests
async, instead of sequentially blocking as the `described_groups()` used
to do.</pre>
</div>
</content>
</entry>
<entry>
<title>Lint cleanup (#2126)</title>
<updated>2020-09-17T17:41:39+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2020-09-17T17:41:39+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=6cfe706d1ab4eaa7c970f19ce102f65625affb96'/>
<id>6cfe706d1ab4eaa7c970f19ce102f65625affb96</id>
<content type='text'>
Small cleanup leftover from https://github.com/dpkp/kafka-python/pull/2035</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Small cleanup leftover from https://github.com/dpkp/kafka-python/pull/2035</pre>
</div>
</content>
</entry>
<entry>
<title>Feature: delete consumergroups (#2040)</title>
<updated>2020-09-17T16:17:35+00:00</updated>
<author>
<name>Swen Wenzel</name>
<email>5111028+swenzel@users.noreply.github.com</email>
</author>
<published>2020-09-17T16:17:35+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=16a0b3155fdeebe80295fcfb0f32d75af74dcb1a'/>
<id>16a0b3155fdeebe80295fcfb0f32d75af74dcb1a</id>
<content type='text'>
* Add consumergroup related errors
* Add DeleteGroups to protocol.admin
* Implement delete_groups feature on KafkaAdminClient</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Add consumergroup related errors
* Add DeleteGroups to protocol.admin
* Implement delete_groups feature on KafkaAdminClient</pre>
</div>
</content>
</entry>
<entry>
<title>Allow configurable timeouts in admin client check version</title>
<updated>2020-09-17T01:02:37+00:00</updated>
<author>
<name>Himanshu Mishra</name>
<email>sigmablazer@gmail.com</email>
</author>
<published>2020-08-22T21:56:21+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=b32f369e5a4b9914e92b4818b4d1bc6152264ec5'/>
<id>b32f369e5a4b9914e92b4818b4d1bc6152264ec5</id>
<content type='text'>
Currently there's no way to pass timeout to check_version if called from admin.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Currently there's no way to pass timeout to check_version if called from admin.</pre>
</div>
</content>
</entry>
<entry>
<title>Enhancement for Kafka Admin Client's "Describe Consumer Group" (#2035)</title>
<updated>2020-09-17T00:33:45+00:00</updated>
<author>
<name>Apurva007</name>
<email>apurvatelang15@gmail.com</email>
</author>
<published>2020-09-17T00:33:45+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=26b8400ecafe9853bbb8ee3caf04a0a53eb6b224'/>
<id>26b8400ecafe9853bbb8ee3caf04a0a53eb6b224</id>
<content type='text'>
Adding namedtuples for DescribeConsumerGroup response; Adding Serialization of MemberData and MemberAssignment for the response

Co-authored-by: Apurva Telang &lt;atelang@paypal.com&gt;
Co-authored-by: Jeff Widman &lt;jeff@jeffwidman.com&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Adding namedtuples for DescribeConsumerGroup response; Adding Serialization of MemberData and MemberAssignment for the response

Co-authored-by: Apurva Telang &lt;atelang@paypal.com&gt;
Co-authored-by: Jeff Widman &lt;jeff@jeffwidman.com&gt;</pre>
</div>
</content>
</entry>
<entry>
<title>KAFKA-8962: Use least_loaded_node() for describe_topics()</title>
<updated>2020-02-16T22:54:06+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2020-02-16T18:11:32+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=3c3fdc11b555756c53ae63bfa46a915eab48f448'/>
<id>3c3fdc11b555756c53ae63bfa46a915eab48f448</id>
<content type='text'>
In KAFKA-8962 the `AdminClient.describe_topics()` call was changed from
using the controller to using the `least_loaded_node()`:
https://github.com/apache/kafka/commit/317089663cc7ff4fdfcba6ee434f455e8ae13acd#diff-6869b8fccf6b098cbcb0676e8ceb26a7R1540

As a result, no metadata request/response processing needs to happen
through the controller, so it's safe to remove the custom
error-checking. Besides, I don't think this error-checking even added
any value because AFAIK no metadata response would return a
`NotControllerError` because the recipient broker wouldn't realize the
metadata request was intended for only the controller.

Originally our admin client was implemented using the least-loaded-node,
then later updated to the controller. So updating it back to
least-loaded node is a simple case of reverting the associated commits.

This reverts commit 7195f0369c7dbe25aea2c3fed78d2b4f772d775b.

This reverts commit 6e2978edee9a06e9dbe60afcac226b27b83cbc74.

This reverts commit f92889af79db08ef26d89cb18bd48c7dd5080010.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
In KAFKA-8962 the `AdminClient.describe_topics()` call was changed from
using the controller to using the `least_loaded_node()`:
https://github.com/apache/kafka/commit/317089663cc7ff4fdfcba6ee434f455e8ae13acd#diff-6869b8fccf6b098cbcb0676e8ceb26a7R1540

As a result, no metadata request/response processing needs to happen
through the controller, so it's safe to remove the custom
error-checking. Besides, I don't think this error-checking even added
any value because AFAIK no metadata response would return a
`NotControllerError` because the recipient broker wouldn't realize the
metadata request was intended for only the controller.

Originally our admin client was implemented using the least-loaded-node,
then later updated to the controller. So updating it back to
least-loaded node is a simple case of reverting the associated commits.

This reverts commit 7195f0369c7dbe25aea2c3fed78d2b4f772d775b.

This reverts commit 6e2978edee9a06e9dbe60afcac226b27b83cbc74.

This reverts commit f92889af79db08ef26d89cb18bd48c7dd5080010.
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix topic error parsing in MetadataResponse</title>
<updated>2020-02-16T06:32:30+00:00</updated>
<author>
<name>Jeff Tribble</name>
<email>jtribble@newrelic.com</email>
</author>
<published>2020-02-11T22:22:15+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=7195f0369c7dbe25aea2c3fed78d2b4f772d775b'/>
<id>7195f0369c7dbe25aea2c3fed78d2b4f772d775b</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>_send_request_to_controller returns a raw result, not a future</title>
<updated>2020-02-06T22:20:40+00:00</updated>
<author>
<name>Tyler Lubeck</name>
<email>tyler@coffeemeetsbagel.com</email>
</author>
<published>2020-02-06T21:41:45+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=6e2978edee9a06e9dbe60afcac226b27b83cbc74'/>
<id>6e2978edee9a06e9dbe60afcac226b27b83cbc74</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Use the controller for topic metadata requests</title>
<updated>2020-02-06T22:20:40+00:00</updated>
<author>
<name>Tyler Lubeck</name>
<email>tyler@coffeemeetsbagel.com</email>
</author>
<published>2020-02-06T21:31:05+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=f92889af79db08ef26d89cb18bd48c7dd5080010'/>
<id>f92889af79db08ef26d89cb18bd48c7dd5080010</id>
<content type='text'>
Closes #1994
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Closes #1994
</pre>
</div>
</content>
</entry>
<entry>
<title>Implement list_topics, describe_topics, and describe_cluster</title>
<updated>2020-02-06T21:10:08+00:00</updated>
<author>
<name>Tyler Lubeck</name>
<email>tylerl@surveymonkey.com</email>
</author>
<published>2019-11-15T18:54:48+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=da01fef9b9685cc95fe1a8dd420e841b9c63e8c3'/>
<id>da01fef9b9685cc95fe1a8dd420e841b9c63e8c3</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
