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

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.

Add protocols for {Describe,Create,Delete} Acls

2018-11-20T00:59:49+00:00

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Pre-compile pack/unpack function calls

2018-10-29T19:57:42+00:00

I noticed that pack/unpack functions from
https://github.com/dpkp/kafka-python/blob/master/kafka/protocol/types.py
might be slightly improved. I made pre-compilation for them. It gives
about 10% better performance compared to the current implementation.

Consumption of 100msg:
```
239884    0.187    0.000    0.287    0.000 types.py:18(_unpack) # new version
239884    0.192    0.000    0.323    0.000 types.py:17(_unpack)
```

I also made some profiling for producers/consumers. It gives about
1-1.5% time savings.

Add KafkaAdmin class

2018-10-25T05:42:12+00:00

Requires cluster version > 0.10.0.0, and uses new wire protocol
classes to do many things via broker connection that previously
needed to be done directly in zookeeper.

Don't use `kafka.common` internally

2018-06-05T21:32:01+00:00

This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.

Added AlterConfigs and DescribeConfigs apis (#1472)

2018-04-18T21:55:49+00:00

Fix CreatePartitionsRequest_v0 (#1469)

2018-04-05T20:44:54+00:00

Fix error var name in _unpack (#1403)

2018-03-05T09:34:27+00:00

Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19