Skip to content

Version 1.3.0 (2015-04-16)
Compare
Choose a tag to compare
@eapache eapache released this 16 Apr 20:29
v1.3.0
4744176

New Features:

  • The client now tracks consumer group coordinators using
    ConsumerMetadataRequests similar to how it tracks partition leadership using
    regular MetadataRequests (#411).
    This adds two methods to the client API:
    • Coordinator(consumerGroup string) (*Broker, error)
    • RefreshCoordinator(consumerGroup string) error

Improvements:

  • ConsumerMetadataResponses now automatically create a Broker object out of the
    ID/address/port combination for the Coordinator; accessing the fields
    individually has been deprecated
    (#413).
  • Much improved handling of OffsetOutOfRange errors in the consumer.
    Consumers will fail to start if the provided offset is out of range
    (#418)
    and they will automatically shut down if the offset falls out of range
    (#424).
  • Small performance improvement in encoding and decoding protocol messages
    (#427).

Bug Fixes:

  • Fix a rare race condition in the client's background metadata refresher if
    it happens to be activated while the client is being closed
    (#422).
Assets 2
Loading