delta/python-packages/kafka-python.git/test/test_coordinator.py, branch 2.0.2

KIP-54: Implement sticky partition assignment strategy (#2057)

2020-09-30T04:03:54+00:00

Use ==/!= to compare str, bytes, and int literals

2020-02-05T23:25:13+00:00

Identity is not the same thing as equality in Python so use ==/!= to compare str, bytes, and int literals. In Python >= 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__
```
>>> consumer = "cons"
>>> consumer += "umer"
>>> consumer == "consumer"
True
>>> consumer is "consumer"
False
>>> 0 == 0.0
True
>>> 0 is 0.0
False
```

Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)

2019-12-30T00:06:24+00:00

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`.

KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)

2018-02-03T00:36:30+00:00

Minor test cleanups (#1343)

2018-01-12T20:49:01+00:00

Fix coordinator join_future race condition (#1338)

2018-01-11T22:48:38+00:00

* Fix race condition in coordinator join_future handling

KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

2017-12-21T22:46:10+00:00

Handle lookup_coordinator send failures (#1279)

2017-10-24T23:05:50+00:00

KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)

2017-10-12T00:11:31+00:00