|
1 | 1 | Changelog |
2 | 2 | ========= |
3 | 3 |
|
| 4 | +2.8.0-dev.2 (2018-6-14) |
| 5 | +----------------------- |
| 6 | + |
| 7 | +`Compare 2.8.0-dev.2`_ |
| 8 | + |
| 9 | +.. _Compare 2.8.0-dev.2: https://github.com/Parsely/pykafka/compare/2.8.0-dev.1...2.8.0-dev.2 |
| 10 | + |
| 11 | +Minor Version Features |
| 12 | +---------------------- |
| 13 | + |
| 14 | +* Added a `partition_offsets` kwarg to consumers' `commit_offsets` method to decouple |
| 15 | + the notions of "committed" vs "consumed" messages |
| 16 | +* Added an `attempts` kwarg to `Broker.connect` that controls retries during broker |
| 17 | + connection |
| 18 | +* Added a `queue_empty_timeout_ms` kwarg to `Producer.__init__` that creates an "empty |
| 19 | + wait" state in the `Producer` when no messages are available to produce |
| 20 | + |
| 21 | +Bugfixes |
| 22 | +-------- |
| 23 | + |
| 24 | +* Updated some `cli.print_managed_consumer_groups` to be Py3 compatible |
| 25 | +* Updated the topic creation/deletion CLI to avoid trying to talk to 0.10.0 brokers |
| 26 | +* Improved error handling in `Cluster.get_group_coordinator` |
| 27 | +* Added retry logic to `BrokerConnection.connect` |
| 28 | +* Handled some nuisance errors when shutting down in `handlers.py` |
| 29 | +* Added a `threading.Event` instance to `Producer` indicating the presence of at least |
| 30 | + one message in the queue to enable nonbusy "empty waiting" |
| 31 | +* Added logic to `SimpleConsumer.commit_offsets` and |
| 32 | + `OwnedPartition.build_offset_commit_request` that handles user-specified offset |
| 33 | + information and sends it in requests |
| 34 | + |
| 35 | +Miscellaneous |
| 36 | +------------- |
| 37 | + |
| 38 | +* Updated version of Kafka used in Travis tests to 1.0.1 |
| 39 | +* Added usage guide section on connection loss |
| 40 | +* Updated test harness to allow simulated killing of brokers |
| 41 | +* Added a giant explanatory docstring to `Topic.fetch_offset_limits` clarifying how the |
| 42 | + `ListOffsets` API works |
| 43 | +* Pinned `gevent` dependency to avoid breaking change in `kazoo`, which depends on it |
| 44 | +* Added tests for retrying broker connections |
| 45 | +* Added tests for user-specified offset commits |
| 46 | + |
4 | 47 | 2.8.0-dev.1 (2018-3-14) |
5 | 48 | ----------------------- |
6 | 49 |
|
|
0 commit comments