Releases: influxdata/rskafka
Releases · influxdata/rskafka
0.5.0 -- SASL, Backoff Configs
0.4.0 -- More Stability
Breaking
Features
- topic deletion (#191)
- respect throttling (#184)
- allow setting a custom client ID (#180)
- pub ProducerClient for instrumentation hook (#162)
- add some getters to
PartitionClient
(#154)
Improvements
- log metadata mode in
get_leader
(#188) - log reason about WHY we invalidate caches (#185)
- remove interior mutable from
Messenger::version_ranges
(#183) - async flushing & buffering + lock contention (#173)
- pre-warm cache broker connections (#166)
- support pre-warming PartitionClient (#165)
- metadata cache for leader discovery (#163)
- extend
ServerError
with helpful data (#160) - speed up IO (#156)
Bug Fixes
- (potential) broker cache invalidation race (#187)
- (potential) metadata cache invalidation race (#186)
- Fix typo in error message (#158)
- use compact arrays where needed (#155)
Dependency Updates
0.3.0 -- Bug Fixes, Small API Improvements
0.2.0 -- Essential Bug Fixes, Compression
Breaking Changes
Record::{key,value}
are now optional, following the underlying Kafka protocol (#93)- compression support,
PartitionClient::produce
requirescompression
parameter (#82, #91, #92, #94) PartitionClient::get_high_watermark
was replaced byPartitionClient::get_offset
(#100)StreamConsumer::new
start_offset
parameter changed fromi64
toStartOffset
type (#104)- rework features (#107)
Features
- record deletion (#97)
Bug Fixes
- ignore
InvalidReplicationFactor
(#106) - fix rare panic in
BatchProducer
(#105) - filter out records that were not requested (#99)
- terminate consumer stream on
OffsetOutOfRange
(#96)
Performance
- faster CRC calculation (#85)
0.1.0 -- Initial Release
This is the first release featuring:
- tokio-based async connection handling
- TLS and SOCKS5 support
- listing topics
- create a topic
- produce records (w/o compression)
- consume records (w/o compression)
- basic consumer streams
- framework to set up record batching