<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/cluster.py, 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>Do not log topic-specific errors in full metadata fetch (#1980)</title>
<updated>2019-12-30T00:06:58+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-12-30T00:06:58+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=46882a8aaf02ed026e5126f28293abc8fdd9b023'/>
<id>46882a8aaf02ed026e5126f28293abc8fdd9b023</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Use dedicated connection for group coordinator (#1822)</title>
<updated>2019-06-19T20:41:59+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-06-19T20:41:59+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=91f4642e92afc208531f66cea1ed7ef32bcfa4d1'/>
<id>91f4642e92afc208531f66cea1ed7ef32bcfa4d1</id>
<content type='text'>
This changes the coordinator_id to be a unique string, e.g., `coordinator-1`, so that it will get a dedicated connection. This won't eliminate lock contention because the client lock applies to all connections, but it should improve in-flight-request contention.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This changes the coordinator_id to be a unique string, e.g., `coordinator-1`, so that it will get a dedicated connection. This won't eliminate lock contention because the client lock applies to all connections, but it should improve in-flight-request contention.</pre>
</div>
</content>
</entry>
<entry>
<title>Remove unused imports (#1808)</title>
<updated>2019-05-23T04:56:25+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2019-05-23T04:56:25+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=edfafc036f0d9a3b1e5c73f9642ef71c297c1b64'/>
<id>edfafc036f0d9a3b1e5c73f9642ef71c297c1b64</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Maintain shadow cluster metadata for bootstrapping (#1753)</title>
<updated>2019-03-22T04:03:42+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-03-22T04:03:42+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=af2dd48de338cac07b88805b8f2b23ee2e694502'/>
<id>af2dd48de338cac07b88805b8f2b23ee2e694502</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Retry bootstrapping after backoff when necessary (#1736)</title>
<updated>2019-03-14T16:39:28+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-03-14T16:39:28+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=812de351f75beefe73bd9bef55847ab61ccc951d'/>
<id>812de351f75beefe73bd9bef55847ab61ccc951d</id>
<content type='text'>
The current client attempts to bootstrap once during initialization, but if it fails there is no second attempt and the client will be inoperable. This can happen, for example, if an entire cluster is down at the time a long-running client starts execution.

This commit attempts to fix this by removing the synchronous bootstrapping from `KafkaClient` init, and instead merges bootstrap metadata with the cluster metadata. The Java client uses a similar approach. This allows us to continue falling back to bootstrap data when necessary throughout the life of a long-running consumer or producer.

Fix #1670</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
The current client attempts to bootstrap once during initialization, but if it fails there is no second attempt and the client will be inoperable. This can happen, for example, if an entire cluster is down at the time a long-running client starts execution.

This commit attempts to fix this by removing the synchronous bootstrapping from `KafkaClient` init, and instead merges bootstrap metadata with the cluster metadata. The Java client uses a similar approach. This allows us to continue falling back to bootstrap data when necessary throughout the life of a long-running consumer or producer.

Fix #1670</pre>
</div>
</content>
</entry>
<entry>
<title>Ignore MetadataResponses with empty broker list (#1506)</title>
<updated>2018-05-26T15:43:25+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-05-26T15:43:25+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ee26c3f547f357d639b421b3e38a74e87e21f346'/>
<id>ee26c3f547f357d639b421b3e38a74e87e21f346</id>
<content type='text'>

</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>

</pre>
</div>
</content>
</entry>
<entry>
<title>Document methods that return None</title>
<updated>2018-05-23T22:19:35+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-05-22T18:33:36+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=c9d783a8211337205bc90c27d1f67beb65ac5d9e'/>
<id>c9d783a8211337205bc90c27d1f67beb65ac5d9e</id>
<content type='text'>
If a valid broker in the cluster has no partitions, it will return None rather than an empty set.

Similarly updated a few other methods.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
If a valid broker in the cluster has no partitions, it will return None rather than an empty set.

Similarly updated a few other methods.</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>KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)</title>
<updated>2018-02-03T00:36:30+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-02-03T00:36:30+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=618c5051493693c1305aa9f08e8a0583d5fcf0e3'/>
<id>618c5051493693c1305aa9f08e8a0583d5fcf0e3</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add ClusterMetadata documentation</title>
<updated>2017-03-07T20:24:55+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2017-03-07T19:33:23+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=a4338169d4e87536ed2e81ce41d9276e2f3d73a9'/>
<id>a4338169d4e87536ed2e81ce41d9276e2f3d73a9</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
