Skip to content

0.2.0 -- Essential Bug Fixes, Compression

Choose a tag to compare

@crepererum crepererum released this 17 Feb 09:47

Breaking Changes

  • Record::{key,value} are now optional, following the underlying Kafka protocol (#93)
  • compression support, PartitionClient::produce requires compression parameter (#82, #91, #92, #94)
  • PartitionClient::get_high_watermark was replaced by PartitionClient::get_offset (#100)
  • StreamConsumer::new start_offset parameter changed from i64 to StartOffset 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)