3 releases

new 0.2.14-alpha Jan 30, 2023
0.2.13-alpha Jan 12, 2023
0.2.8-alpha Sep 26, 2022

#27 in Simulation

Download history 169/week @ 2022-10-09 153/week @ 2022-10-16 135/week @ 2022-10-23 127/week @ 2022-10-30 160/week @ 2022-11-06 190/week @ 2022-11-13 179/week @ 2022-11-20 250/week @ 2022-11-27 199/week @ 2022-12-04 132/week @ 2022-12-11 150/week @ 2022-12-18 135/week @ 2022-12-25 176/week @ 2023-01-01 278/week @ 2023-01-08 173/week @ 2023-01-15 120/week @ 2023-01-22

762 downloads per month

Apache-2.0

445KB
9K SLoC

madsim-rdkafka

Crate Docs

The rdkafka simulator on madsim. Mirrors rdkafka v0.29.0.

Usage

Replace all rdkafka entries in your Cargo.toml:

[dependencies]
rdkafka = { version = "0.2.13-alpha", package = "madsim-rdkafka" }

API Modification

This crate roughly follows the rdkafka API but is NOT exactly the same.

The following functions are modified to be async:

  • FromClientConfig::from_config
  • FromClientConfigAndContext::from_config_and_context
  • ClientConfig::create
  • ClientConfig::create_with_context
  • Client::fetch_metadata
  • Client::fetch_watermarks
  • Client::fetch_group_list
  • Consumer::seek
  • Consumer::commit
  • Consumer::commit_consumer_state
  • Consumer::commit_message
  • Consumer::committed
  • Consumer::committed_offsets
  • Consumer::offsets_for_timestamp
  • Consumer::offsets_for_times
  • Consumer::fetch_metadata
  • Consumer::fetch_watermarks
  • Consumer::fetch_group_list
  • Producer::flush
  • Producer::init_transactions
  • Producer::send_offsets_to_transaction
  • Producer::commit_transaction
  • Producer::abort_transaction

Dependencies

~0–12MB
~215K SLoC