delta/python-packages/kafka-python.git/kafka/protocol, branch 2.0.2

Feature: delete consumergroups (#2040)

2020-09-17T16:17:35+00:00

* Add consumergroup related errors
* Add DeleteGroups to protocol.admin
* Implement delete_groups feature on KafkaAdminClient

Add support for `zstd` compression (#2021)

2020-09-07T23:11:18+00:00

Add logic for inferring newer broker versions (#2038)

2020-05-05T11:29:23+00:00

* 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

Add `log_start_offset` to message protocol parsing (#2020)

2020-03-25T15:05:36+00:00

This is in preparation for adding `zstd` support.

Implement methods to convert a Struct object to a pythonic object (#1951)

2020-02-06T20:27:09+00:00

Implement methods to convert a Struct object to a pythonic object

Remove some dead code

2020-02-05T23:57:01+00:00

Admin protocol updates (#1948)

2019-12-29T23:47:32+00:00

Remove SimpleClient, Producer, Consumer, Unittest (#1196)

2019-10-11T19:03:22+00:00

In the 2.0 release, we're removing:
 * `SimpleClient`
 * `SimpleConsumer`
 * `SimpleProducer`
 * Old partitioners used by `SimpleProducer`; these are superceded by
 the `DefaultPartitioner`

These have been deprecated for several years in favor of `KafkaClient`
/ `KafkaConsumer` / `KafkaProducer`.

Since 2.0 allows breaking changes, we are removing the deprecated
classes.

Additionally, since the only usage of `unittest` was in tests for these
old Simple* clients, this also drops `unittest` from the library. All
tests now run under `pytest`.

Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)

2019-03-27T14:45:50+00:00

Fix response error checking in KafkaAdminClient send_to_controller

2019-01-03T21:46:47+00:00

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.