<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/test, branch master</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>Core Protocol: Add support for flexible versions (#2151)</title>
<updated>2020-12-02T14:45:13+00:00</updated>
<author>
<name>Tincu Gabriel</name>
<email>gabi@aiven.io</email>
</author>
<published>2020-12-02T14:45:13+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=9feeb79140ed10e3a7f2036491fc07573740c231'/>
<id>9feeb79140ed10e3a7f2036491fc07573740c231</id>
<content type='text'>
- Add support for new request and response headers, supporting flexible
versions / tagged fields
- Add List / Alter partition reassignments APIs
- Add support for varints
- Add support for compact collections (byte array, string, array)</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
- Add support for new request and response headers, supporting flexible
versions / tagged fields
- Add List / Alter partition reassignments APIs
- Add support for varints
- Add support for compact collections (byte array, string, array)</pre>
</div>
</content>
</entry>
<entry>
<title>Cover sticky assignor's metadata method with tests (#2161)</title>
<updated>2020-11-06T05:00:38+00:00</updated>
<author>
<name>Valeria Chernenko</name>
<email>aynroot@users.noreply.github.com</email>
</author>
<published>2020-11-06T05:00:38+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=b090b21f07a1c7b89afb5dc36114aa2d37c580f0'/>
<id>b090b21f07a1c7b89afb5dc36114aa2d37c580f0</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>KIP-54: Implement sticky partition assignment strategy (#2057)</title>
<updated>2020-09-30T04:03:54+00:00</updated>
<author>
<name>Valeria Chernenko</name>
<email>aynroot@users.noreply.github.com</email>
</author>
<published>2020-09-30T04:03:54+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=c536dd28bc3c2db85d9b62a1e73d23a3eeaebd93'/>
<id>c536dd28bc3c2db85d9b62a1e73d23a3eeaebd93</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</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>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>Add support for `zstd` compression (#2021)</title>
<updated>2020-09-07T23:11:18+00:00</updated>
<author>
<name>Tincu Gabriel</name>
<email>gabi@aiven.io</email>
</author>
<published>2020-09-07T23:11:18+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=a27ab881726ed1a2d952867a1fa266573165d6aa'/>
<id>a27ab881726ed1a2d952867a1fa266573165d6aa</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add logic for inferring newer broker versions (#2038)</title>
<updated>2020-05-05T11:29:23+00:00</updated>
<author>
<name>Tincu Gabriel</name>
<email>gabi@aiven.io</email>
</author>
<published>2020-05-05T11:29:23+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=6fc008137c75c751a9fbea3e0ef36d2870119c7b'/>
<id>6fc008137c75c751a9fbea3e0ef36d2870119c7b</id>
<content type='text'>
* Add logic for inferring newer broker versions

- New Fetch / ListOffsets request / response objects
- Add new test cases to inferr code based on mentioned objects
- Add unit test to check inferred version against whatever resides in KAFKA_VERSION
- Add new kafka broker versions to integration list
- Add more kafka broker versions to travis task list
- Add support for broker version 2.5 id

* Implement PR change requests: fewer versions for travis testing, remove unused older versions for inference code, remove one minor version from known server list
Do not use newly created ACL request / responses in allowed version lists, due to flexible versions enabling in kafka actually requiring a serialization protocol header update
Revert admin client file change</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Add logic for inferring newer broker versions

- New Fetch / ListOffsets request / response objects
- Add new test cases to inferr code based on mentioned objects
- Add unit test to check inferred version against whatever resides in KAFKA_VERSION
- Add new kafka broker versions to integration list
- Add more kafka broker versions to travis task list
- Add support for broker version 2.5 id

* Implement PR change requests: fewer versions for travis testing, remove unused older versions for inference code, remove one minor version from known server list
Do not use newly created ACL request / responses in allowed version lists, due to flexible versions enabling in kafka actually requiring a serialization protocol header update
Revert admin client file change</pre>
</div>
</content>
</entry>
<entry>
<title>Implement methods to convert a Struct object to a pythonic object (#1951)</title>
<updated>2020-02-06T20:27:09+00:00</updated>
<author>
<name>Tyler Lubeck</name>
<email>tyler@coffeemeetsbagel.com</email>
</author>
<published>2020-02-06T20:27:09+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=209515bf9dcdd9e03bc286035641af3ae72fcbf9'/>
<id>209515bf9dcdd9e03bc286035641af3ae72fcbf9</id>
<content type='text'>
Implement methods to convert a Struct object to a pythonic object</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Implement methods to convert a Struct object to a pythonic object</pre>
</div>
</content>
</entry>
<entry>
<title>Use ==/!= to compare str, bytes, and int literals</title>
<updated>2020-02-05T23:25:13+00:00</updated>
<author>
<name>Christian Clauss</name>
<email>cclauss@me.com</email>
</author>
<published>2020-01-10T08:09:50+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=7008fd44f545f0794030dc73d9e1d3115ec9e88d'/>
<id>7008fd44f545f0794030dc73d9e1d3115ec9e88d</id>
<content type='text'>
Identity is not the same thing as equality in Python so use ==/!= to compare str, bytes, and int literals. In Python &gt;= 3.8, these instances will raise __SyntaxWarnings__ so it is best to fix them now. https://docs.python.org/3.8/whatsnew/3.8.html#porting-to-python-3-8

% __python__
```
&gt;&gt;&gt; consumer = "cons"
&gt;&gt;&gt; consumer += "umer"
&gt;&gt;&gt; consumer == "consumer"
True
&gt;&gt;&gt; consumer is "consumer"
False
&gt;&gt;&gt; 0 == 0.0
True
&gt;&gt;&gt; 0 is 0.0
False
```</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Identity is not the same thing as equality in Python so use ==/!= to compare str, bytes, and int literals. In Python &gt;= 3.8, these instances will raise __SyntaxWarnings__ so it is best to fix them now. https://docs.python.org/3.8/whatsnew/3.8.html#porting-to-python-3-8

% __python__
```
&gt;&gt;&gt; consumer = "cons"
&gt;&gt;&gt; consumer += "umer"
&gt;&gt;&gt; consumer == "consumer"
True
&gt;&gt;&gt; consumer is "consumer"
False
&gt;&gt;&gt; 0 == 0.0
True
&gt;&gt;&gt; 0 is 0.0
False
```</pre>
</div>
</content>
</entry>
<entry>
<title>Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)</title>
<updated>2019-12-30T00:06:24+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2019-12-30T00:06:24+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=2a86b23f477e5ed57aa987db97d11284a37d05a0'/>
<id>2a86b23f477e5ed57aa987db97d11284a37d05a0</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
