Bot releases are hidden (Show)
Published by bai about 5 years ago
New Features:
Improvements:
Bug Fixes:
Known Issues:
Published by d1egoaz about 5 years ago
Published by bai over 5 years ago
New Features:
Improvements:
Bug Fixes:
Published by bai over 5 years ago
Published by bai over 5 years ago
New Features:
Improvements:
Bug Fixes:
Published by bai over 5 years ago
New Features:
Improvements:
Bug Fixes:
Published by vvuibert almost 6 years ago
New Features:
Improvements:
Bug Fixes:
Published by bai almost 6 years ago
New Features:
Improvements:
Bug Fixes:
Published by bai about 6 years ago
Published by bai about 6 years ago
New Features:
Partitioner.RequiresConsistency
vary per-message (#1112).ClusterAdmin
support for CreateTopic
, DeleteTopic
, CreatePartitions
, DeleteRecords
, DescribeConfig
, AlterConfig
, CreateACL
, ListAcls
, DeleteACL
(#1055).Improvements:
LocalAddr
when dialing an address to support multi-homed hosts (#1123).Bug Fixes:
ProducerMessage.MetaData
when producing to Kafka (#1110).MetadataRequest
for empty list of topics (#1132).Published by bai over 6 years ago
New Features:
Controller()
method to Client interface (#1063).Improvements:
msgSet
and recordBatch
(#1049).Bug Fixes:
Published by eapache over 6 years ago
New Features:
Improvements:
NewMockBrokerListener
helper for testing TLS connections (#1019).Consumer.Fetch.Default
from 32KiB to 1MiB which results in much higher throughput in most cases (#1024).time.Ticker
across fetch requests in the PartitionConsumer to reduce CPU and memory usage when processing many partitions (#1028).Bug Fixes:
PartialTrailingMessage
when the partial message was truncated before the magic value indicating its version (#1030).SyncProducer.SendMessages
(#1035).Published by eapache almost 7 years ago
Published by eapache almost 7 years ago
New Features:
Bug Fixes:
Published by eapache about 7 years ago
New Features:
PartitionOffsetManager.ResetOffset
for backtracking tracked offsets (#932).Improvements:
Client.Replicas
and Client.InSyncReplicas
now respect the order returned by the broker, which can be meaningful (#930).Ticker
to reduce consumer timer overhead at the cost of higher variance in the actual timeout (#933).Bug Fixes:
Published by eapache over 7 years ago
New Features:
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.Brokers
method to the Client which returns the complete set of active brokers (#813).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).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:
Bug Fixes:
AddGroupProtocol
or AddGroupProtocolMetadata
helpers; otherwise you will need to switch from the GroupProtocols
field (now deprecated) to use OrderedGroupProtocols
(#812).Published by eapache almost 8 years ago
New Features:
HighWaterMarks
method to the Consumer which aggregates theHighWaterMarkOffset
values of its child topic/partitionsBug Fixes:
Published by eapache about 8 years ago
Bug Fixes:
HashPartitioner
which was incorrectPublished by eapache about 8 years ago
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:
Improvements:
nil
compressed messages for deleting in compacted topicsBug Fixes:
Client.Leader
could return the wrong errorPublished by eapache over 8 years ago
New Features:
Improvements:
Bug Fixes: