0.6.0 -- SASL Additions, Better Errors, Timestamp Offset, Code Modernization
- MSRV is now 1.85, rskafka now uses Rust version 2024 (#218, #231, #238, #245, #257)
- improve error handling (#230)
- support SASL SCRAM (#247) and OAUTHTOKEN (#253), fix PLAIN (#255)
- support
OffsetAt::Timestamp(#248)
- remove reference to IOx from README (#250)
- drop async-trait (#245)
- async-socks5 to 0.6 (#232)
- crc32c to 0.6.5 (#231)
- drop pin-project-lite (#246)
- ring is hardcoded as a crypto provider (#233)
- rustls to 0.23 (#227, #233)
- tokio-rustls to 0.26 (#227, #233)
- zstd to 0.13 (#223)
- cargo deny config fixed/updated (#243, #251)
- CI fixes (#254)
- j4rs to 0.20.0 (#236, #237, #238)
- drop procspawn (#222, #244)
- proptest-derive to 0.5 (#220, #240)
- rdkafka to 0.35 (#221, #229, #242, #260)
- rustls-pemfile to 2.0 (#226)
- tracing-log to 0.2 (#224)
0.4.0 -- More Stability
- switch from
timetochrono(#176, #196) - make errors non-exhaustive (#159)
- 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)
- 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
ServerErrorwith helpful data (#160) - speed up IO (#156)
- (potential) broker cache invalidation race (#187)
- (potential) metadata cache invalidation race (#186)
- Fix typo in error message (#158)
- use compact arrays where needed (#155)
dotenv->dotenvy(#161)rustlsto 0.21 (#200)zstdto 0.12 (#195)criterion(dev dependency) to 0.4 (#177, #204)j4rs(dev dependency) to 0.15 (#193, #197)rdkafka(dev dependency) to 0.31 (#189, #202, #203)- CI rust toolchain to 1.65 (#194)
0.3.0 -- Bug Fixes, Small API Improvements
- assorted DX and infrastructure improvements (#116, #123, #127, #128, #135, #138, #145, #146)
- convert some
ascasts to proper conversion (#117, #118, #120, #121) - make
Client::{controller,partition}_clientsync (#136)
rustls-pemfileto 1.0 (#126)uuidto 1.0 (#131)
- multiple cancellation and panic safety fixes (#113, #115)
- Java interopt, esp. for Snappy-compressed messages (#108)
- fix potential OOM cases (#138, #141)
- remove potentially buggy Redpanda quirk (#150)
- documentation (#151)
0.2.0 -- Essential Bug Fixes, Compression
Record::{key,value}are now optional, following the underlying Kafka protocol (#93)- compression support,
PartitionClient::producerequirescompressionparameter (#82, #91, #92, #94) PartitionClient::get_high_watermarkwas replaced byPartitionClient::get_offset(#100)StreamConsumer::newstart_offsetparameter changed fromi64toStartOffsettype (#104)- rework features (#107)
- record deletion (#97)
- ignore
InvalidReplicationFactor(#106) - fix rare panic in
BatchProducer(#105) - filter out records that were not requested (#99)
- terminate consumer stream on
OffsetOutOfRange(#96)
- 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