New Features:
- Claim official support for Kafka 1.0, though it did already work (#984).
- Helper methods for Kafka version numbers to/from strings (#989).
- Implement CreatePartitions request/response (#985).
Improvements:
- Add error codes 45-60 (#986).
Bug Fixes:
- Fix slow consuming for certain Kafka 0.11/1.0 configurations (#982).
- Correctly determine when a FetchResponse contains the new message format (#990).
- Fix producing with multiple headers (#996).
- Fix handling of truncated record batches (#998).
- Fix leaking metrics when closing brokers (#991).
New Features:
- Add support for the new Kafka 0.11 record-batch format, including the wire protocol and the necessary behavioural changes in the producer and consumer. Transactions and idempotency are not yet supported, but producing and consuming should work with all the existing bells and whistles (batching, compression, etc) as well as the new custom headers. Thanks to Vlad Hanciuta of Arista Networks for this work. Part of (#901).
Bug Fixes:
- Fix encoding of ProduceResponse versions in test (#970).
- Return partial replicas list when we have it (#975).
New Features:
- Support for FetchRequest version 3 (#905).
- Permit setting version on mock FetchResponses (#939).
- Add a configuration option to support storing only minimal metadata for extremely large clusters (#937).
- Add
PartitionOffsetManager.ResetOffset
for backtracking tracked offsets (#932).
Improvements:
- Provide the block-level timestamp when consuming compressed messages (#885).
Client.Replicas
andClient.InSyncReplicas
now respect the order returned by the broker, which can be meaningful (#930).- Use a
Ticker
to reduce consumer timer overhead at the cost of higher variance in the actual timeout (#933).
Bug Fixes:
- Gracefully handle messages with negative timestamps (#907).
- Raise a proper error when encountering an unknown message version (#940).
New Features:
- Added support for the
ApiVersions
request and response pair, and Kafka version 0.10.2 (#867). Note that you still need to specify the Kafka version in the Sarama configuration for the time being. - Added a
Brokers
method to the Client which returns the complete set of active brokers (#813). - Added an
InSyncReplicas
method to the Client which returns the set of all in-sync broker IDs for the given partition, now that the Kafka versions for which this was misleading are no longer in our supported set (#872). - Added a
NewCustomHashPartitioner
method which allows constructing a hash partitioner with a custom hash method in case the default (FNV-1a) is not suitable (#837, #841).
Improvements:
- Recognize more Kafka error codes (#859).
Bug Fixes:
- Fix an issue where decoding a malformed FetchRequest would not return the correct error (#818).
- Respect ordering of group protocols in JoinGroupRequests. This fix is
transparent if you're using the
AddGroupProtocol
orAddGroupProtocolMetadata
helpers; otherwise you will need to switch from theGroupProtocols
field (now deprecated) to useOrderedGroupProtocols
(#812). - Fix an alignment-related issue with atomics on 32-bit architectures (#859).
Important: As of Sarama 1.11 it is necessary to set the config value of
Producer.Return.Successes
to true in order to use the SyncProducer. Previous
versions would silently override this value when instantiating a SyncProducer
which led to unexpected values and data races.
New Features:
- Metrics! Thanks to Sébastien Launay for all his work on this feature (#701, #746, #766).
- Add support for LZ4 compression (#786).
- Add support for ListOffsetRequest v1 and Kafka 0.10.1 (#775).
- Added a
HighWaterMarks
method to the Consumer which aggregates theHighWaterMarkOffset
values of its child topic/partitions (#769).
Bug Fixes:
- Fixed producing when using timestamps, compression and Kafka 0.10 (#759).
- Added missing decoder methods to DescribeGroups response (#756).
- Fix producer shutdown when
Return.Errors
is disabled (#787). - Don't mutate configuration in SyncProducer (#790).
- Fix crash on SASL initialization failure (#795).
Bug Fixes:
- Fix the documentation for
HashPartitioner
which was incorrect (#717). - Permit client creation even when it is limited by ACLs (#722).
- Several fixes to the consumer timer optimization code, regressions introduced in v1.10.0. Go's timers are finicky (#730, #733, #734).
- Handle consuming compressed relative offsets with Kafka 0.10 (#735).
Important: As of Sarama 1.10 it is necessary to tell Sarama the version of
Kafka you are running against (via the config.Version
value) in order to use
features that may not be compatible with old Kafka versions. If you don't
specify this value it will default to 0.8.2 (the minimum supported), and trying
to use more recent features (like the offset manager) will fail with an error.
Also: The offset-manager's behaviour has been changed to match the upstream java consumer (see #705 and #713). If you use the offset-manager, please ensure that you are committing one greater than the last consumed message offset or else you may end up consuming duplicate messages.
New Features:
- Support for Kafka 0.10 (#672, #678, #681, and others).
- Support for configuring the target Kafka version (#676).
- Batch producing support in the SyncProducer (#677).
- Extend producer mock to allow setting expectations on message contents (#667).
Improvements:
- Support
nil
compressed messages for deleting in compacted topics (#634). - Pre-allocate decoding errors, greatly reducing heap usage and GC time against misbehaving brokers (#690).
- Re-use consumer expiry timers, removing one allocation per consumed message (#707).
Bug Fixes:
- Actually default the client ID to "sarama" like we say we do (#664).
- Fix a rare issue where
Client.Leader
could return the wrong error (#685). - Fix a possible tight loop in the consumer (#693).
- Match upstream's offset-tracking behaviour (#705).
- Report UnknownTopicOrPartition errors from the offset manager (#706).
- Fix possible negative partition value from the HashPartitioner (#709).
New Features:
- Add support for custom offset manager retention durations (#602).
- Publish low-level mocks to enable testing of third-party producer/consumer implementations (#570).
- Declare support for Golang 1.6 (#611).
- Support for SASL plain-text auth (#648).
Improvements:
Bug Fixes:
- Fix race condition shutting down the OffsetManager (#658).
New Features:
- Full support for Kafka 0.9:
Improvements:
- Optimize for fewer system calls when reading from the network (#584).
- Automatically retry
InvalidMessage
errors to match upstream behaviour (#589).
New Features:
- Preliminary support for Kafka 0.9 (#572). This comes with several caveats:
Improvements:
- Don't wait for request timeouts on dead brokers, greatly speeding recovery when the TCP connection is left hanging (#548).
- Refactored part of the producer. The new version provides a much more elegant solution to #449. It is also slightly more efficient, and much more precise in calculating batch sizes when compression is used (#549, #550, #551).
Bug Fixes:
- Fix race condition in consumer test mock (#553).
Bug Fixes:
- Fix panic that could occur if a user-supplied message value failed to encode (#449).
New Features:
- Implementation of a consumer offset manager using the APIs introduced in Kafka 0.8.2. The API is designed mainly for integration into a future high-level consumer, not for direct use, although it is possible to use it directly. (#461).
Improvements:
- CRC32 calculation is much faster on machines with SSE4.2 instructions, removing a major hotspot from most profiles (#255).
Bug Fixes:
- Make protocol decoding more robust against some malformed packets generated by go-fuzz (#523, #525) or found in other ways (#528).
- Fix a potential race condition panic in the consumer on shutdown (#529).
New Features:
- TLS-encrypted network connections are now supported. This feature is subject to change when Kafka releases built-in TLS support, but for now this is enough to work with TLS-terminating proxies (#154).
Improvements:
- The consumer will not block if a single partition is not drained by the user; all other partitions will continue to consume normally (#485).
- Formatting of error strings has been much improved (#495).
- Internal refactoring of the producer for code cleanliness and to enable future work (#300).
Bug Fixes:
- Fix a potential deadlock in the consumer on shutdown (#475).
Bug Fixes:
- Don't include the partitioner in the producer's "fetch partitions" circuit-breaker (#466).
- Don't retry messages until the broker is closed when abandoning a broker in the producer (#468).
- Update the import path for snappy-go, it has moved again and the API has changed slightly (#486).
Bug Fixes:
- Update the import path for snappy-go, it has moved from google code to github (#456).
Improvements:
- Optimizations when decoding snappy messages, thanks to John Potocny (#446).
Bug Fixes:
New Features:
- The consumer now implements
Topics()
andPartitions()
methods to enable users to dynamically choose what topics/partitions to consume without instantiating a full client (#431). - The partition-consumer now exposes the high water mark offset value returned
by the broker via the
HighWaterMarkOffset()
method (#339). - Added a
kafka-console-consumer
tool capable of handling multiple partitions, and deprecated the now-obsoletekafka-console-partitionConsumer
(#439, #442).
Improvements:
- The producer's logging during retry scenarios is more consistent, more useful, and slightly less verbose (#429).
- The client now shuffles its initial list of seed brokers in order to prevent thundering herd on the first broker in the list (#441).
Bug Fixes:
- The producer now correctly manages its state if retries occur when it is shutting down, fixing several instances of confusing behaviour and at least one potential deadlock (#419).
- The consumer now handles messages for different partitions asynchronously, making it much more resilient to specific user code ordering (#325).
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).
Improvements:
- The producer's behaviour when
Flush.Frequency
is set is now more intuitive (#389). - The producer is now somewhat more memory-efficient during and after retrying messages due to an improved queue implementation (#396).
- The consumer produces much more useful logging output when leadership changes (#385).
- The client's
GetOffset
method will now automatically refresh metadata and retry once in the event of stale information or similar (#394). - Broker connections now have support for using TCP keepalives (#407).
Bug Fixes:
- The OffsetCommitRequest message now correctly implements all three possible API versions (#390, #400).
Improvements:
- Wrap the producer's partitioner call in a circuit-breaker so that repeatedly broken topics don't choke throughput (#373).
Bug Fixes:
- Fix the producer's internal reference counting in certain unusual scenarios (#367).
- Fix the consumer's internal reference counting in certain unusual scenarios (#369).
- Fix a condition where the producer's internal control messages could have gotten stuck (#368).
- Fix an issue where invalid partition lists would be cached when asking for metadata for a non-existant topic (#372).
Version 1.0.0 is the first tagged version, and is almost a complete rewrite. The primary differences with previous untagged versions are:
- The producer has been rewritten; there is now a
SyncProducer
with a blocking API, and anAsyncProducer
that is non-blocking. - The consumer has been rewritten to only open one connection per broker instead of one connection per partition.
- The main types of Sarama are now interfaces to make depedency injection easy; mock implementations for
Consumer
,SyncProducer
andAsyncProducer
are provided in thegh.neting.cc/Shopify/sarama/mocks
package. - For most uses cases, it is no longer necessary to open a
Client
; this will be done for you. - All the configuration values have been unified in the
Config
struct. - Much improved test suite.