| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
|
| |
|
| |
|
| |
|
|
|
|
| |
* only perform single dns lookup for connect_blocking()
* fix blocking timeout in check_version()
|
| |
|
|
|
|
|
| |
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.
|
|
|
|
|
|
|
|
|
|
| |
In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.
Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
(#1457)
|
| |
|
| |
|
| |
|
|
|
|
| |
0 (#1439)
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
for current lookups (#1422)
|
| |
|
| |
|
| |
|
|
|
|
| |
(#1400)
|
|
|
| |
Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19
|
| |
|
| |
|
| |
|