Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Releases: kafka-rust/kafka-rust

Move documentation to docs.rs

26 May 04:55
Compare
Choose a tag to compare
Loading
Pre-release
  • A purely administrative release - no functional changes compared to v0.6.0
  • Move all documentation to docs.rs
Loading

OpenSSL/Snappy dependencies

28 Apr 15:42
Compare
Choose a tag to compare
Loading
Pre-release
  • Update to latest rust-openssl (#122; many thanks to@flier)
  • Replace native snappy dependency with rust-snappy (#116; again many thanks to@flier)
  • Performance improvements by avoiding needless cloning during fetching offsets and API improvements around fetching group offsets (#128; many many thanks to@dead10ck)
  • Replace SipHasher with XxHash (#145)
  • AddedConsumer#subscriptions to inspect the consumed topic-partitions (#137)
  • Started maintaining integration tests (#143; kudos to@dead10ck)
  • Allow borrowing KafkaClient from Consumer/Producer (#136; contributed by@thijsc)
  • Don't send client-id by default; but allow specifying one (#140; contributed by@Morsicus)
Loading

Duration instead of i32-millis

07 Aug 19:02
Compare
Choose a tag to compare
Loading
Pre-release
  • Accept time as astd::time::Duration instead ofi32 millis (Closes:#115)
Loading

Idle connections

04 Aug 04:54
Compare
Choose a tag to compare
Loading
Idle connectionsPre-release
Pre-release
  • Prevent communication over idle connections (#102)
Loading

Producer#send

14 Jul 04:51
Compare
Choose a tag to compare
Loading
Producer#sendPre-release
Pre-release
Loading

Consumer/Producer enhancements

12 Jul 20:22
Compare
Choose a tag to compare
Loading
Pre-release
  • Kafka group offset storage support (#95)
  • Allow consumer to read topics/partitions without a group (breaking api change) (#105)
  • Support for reading multiple topics through consumer (breaking api change) (#31)
  • Type safe required-acks api for sending messages (breaking api change) (#97)
  • Consumer#fallback_offset defaults to "latest" now (#106)
  • Update dependency on crc 1.3 (#98)
  • Properly evaluate compression type for fetched messages (#96)
Loading

Dependency update

16 Jun 20:56
Compare
Choose a tag to compare
Loading

Update byteorder to 0.5

Assets2
Loading

Allow excluding snappy, gzip, openssl through feature guards

05 Jun 18:21
Compare
Choose a tag to compare
Loading

Introduce features to exclude third-party dependencies:

  • "snappy" to exclude dependency on thesnappy crate
  • "gzip" to exclude dependency on theflate2 crate
  • "security" to exclude dependency on theopenssl crate
Loading

Ssl support

19 May 21:40
Compare
Choose a tag to compare
Loading
Ssl supportPre-release
Pre-release
  • Allow Producer/Consumer/KafkaClient to communicate with brokers via SSL -@Hoverbear
Loading

Producer/Consumer extensions

31 Mar 07:48
Compare
Choose a tag to compare
Loading
Pre-release

This release only slightly changes the public API of kafka-rust compared to 0.2.0.

  • Producer will now dispatch messages with the same key to the same partition.
  • One publicunsafe method has been dropped from the fetch response structure..
  • KafkaClient::fetch_messages guarantees to deliver messages withmessage.offset >= partition.requested-offset (this guarantee was previously available only throughConsumer.)
  • KafkaClient::fetch_messages andConsumer will now validate the CRC checksum of fetched messages by default. Since this involves some non-trivial overhead, CRC validation can be turned off.
Loading
Previous1
Previous

[8]ページ先頭

©2009-2025 Movatter.jp