<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/protocol, branch master</title>
<subtitle>github.com: mumrah/kafka-python.git
</subtitle>
<link rel='alternate' type='text/html' href='http://91.123.203.49/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://91.123.203.49/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>Hotfix: TypeError: object of type 'dict_itemiterator' has no len() (#2167)</title>
<updated>2020-11-19T21:51:14+00:00</updated>
<author>
<name>Krzysztof Grabowski</name>
<email>koras@indywidualni.org</email>
</author>
<published>2020-11-19T21:51:14+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=53dc740bce8ef19c32fad2881021d1f6bb055f7a'/>
<id>53dc740bce8ef19c32fad2881021d1f6bb055f7a</id>
<content type='text'>
* Hotfix: TypeError: object of type 'dict_itemiterator' has no len()

* Avoid looping over items 2x

Co-authored-by: Grabowski &lt;chris@crawlinski.com&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Hotfix: TypeError: object of type 'dict_itemiterator' has no len()

* Avoid looping over items 2x

Co-authored-by: Grabowski &lt;chris@crawlinski.com&gt;</pre>
</div>
</content>
</entry>
<entry>
<title>Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162)</title>
<updated>2020-11-15T19:50:46+00:00</updated>
<author>
<name>Lourens Naudé</name>
<email>lourens@methodmissing.com</email>
</author>
<published>2020-11-15T19:50:46+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=8b8a48ba09677e38088c61ade2dab2e42198ab3f'/>
<id>8b8a48ba09677e38088c61ade2dab2e42198ab3f</id>
<content type='text'>
* Co-authored-by: Andrew Brown &lt;andrew.brown@shopify.com&gt;
* Co-authored-by: Aaron Brady &lt;aaron.brady@shopify.com&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Co-authored-by: Andrew Brown &lt;andrew.brown@shopify.com&gt;
* Co-authored-by: Aaron Brady &lt;aaron.brady@shopify.com&gt;</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://91.123.203.49/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>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://91.123.203.49/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://91.123.203.49/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>Add `log_start_offset` to message protocol parsing (#2020)</title>
<updated>2020-03-25T15:05:36+00:00</updated>
<author>
<name>Tincu Gabriel</name>
<email>gabi@aiven.io</email>
</author>
<published>2020-03-25T15:05:36+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=f9e0264e0b0f8d92afb6177d51976795e3bdbcd8'/>
<id>f9e0264e0b0f8d92afb6177d51976795e3bdbcd8</id>
<content type='text'>
This is in preparation for adding `zstd` support.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This is in preparation for adding `zstd` support.</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://91.123.203.49/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>Remove some dead code</title>
<updated>2020-02-05T23:57:01+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2017-08-30T22:09:25+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=6babefab60b05e405fdebde89e27fd8b02848633'/>
<id>6babefab60b05e405fdebde89e27fd8b02848633</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Admin protocol updates (#1948)</title>
<updated>2019-12-29T23:47:32+00:00</updated>
<author>
<name>Tyler Lubeck</name>
<email>tyler@tylerlubeck.com</email>
</author>
<published>2019-12-29T23:47:32+00:00</published>
<link rel='alternate' type='text/html' href='http://91.123.203.49/cgit/delta/python-packages/kafka-python.git/commit/?id=e06ea70174e0b114bec8072371a54ae6bcd73da5'/>
<id>e06ea70174e0b114bec8072371a54ae6bcd73da5</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
