Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

2.8.0-dev.2

Pre-release
Pre-release
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 14 Jun 19:22
· 226 commits to master since this release

Minor Version Features

  • Added a partition_offsets kwarg to consumers' commit_offsets method to decouple
    the notions of "committed" vs "consumed" messages
  • Added an attempts kwarg to Broker.connect that controls retries during broker
    connection
  • Added a queue_empty_timeout_ms kwarg to Producer.__init__ that creates an "empty
    wait" state in the Producer when no messages are available to produce

Bugfixes

  • Updated some cli.print_managed_consumer_groups to be Py3 compatible
  • Updated the topic creation/deletion CLI to avoid trying to talk to 0.10.0 brokers
  • Improved error handling in Cluster.get_group_coordinator
  • Added retry logic to BrokerConnection.connect
  • Handled some nuisance errors when shutting down in handlers.py
  • Added a threading.Event instance to Producer indicating the presence of at least
    one message in the queue to enable nonbusy "empty waiting"
  • Added logic to SimpleConsumer.commit_offsets and
    OwnedPartition.build_offset_commit_request that handles user-specified offset
    information and sends it in requests

Miscellaneous

  • Updated version of Kafka used in Travis tests to 1.0.1
  • Added usage guide section on connection loss
  • Updated test harness to allow simulated killing of brokers
  • Added a giant explanatory docstring to Topic.fetch_offset_limits clarifying how the
    ListOffsets API works
  • Pinned gevent dependency to avoid breaking change in kazoo, which depends on it
  • Added tests for retrying broker connections
  • Added tests for user-specified offset commits