Skip to content
This repository has been archived by the owner on Feb 8, 2024. It is now read-only.

Commit

Permalink
return rdkafka to 0.36 (#73)
Browse files Browse the repository at this point in the history
  • Loading branch information
xvello authored Dec 13, 2023
1 parent 1a7e87a commit 56dfe44
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 6 deletions.
8 changes: 4 additions & 4 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ uuid = { version = "1.3.3", features = ["serde"] }
async-trait = "0.1.68"
serde_urlencoded = "0.7.1"
rand = "0.8.5"
rdkafka = { version = "0.34.0", features = ["cmake-build", "ssl"] }
rdkafka = { version = "0.36.0", features = ["cmake-build", "ssl"] }
metrics = "0.21.1"
metrics-exporter-prometheus = "0.12.1"
thiserror = "1.0.48"
Expand Down
1 change: 0 additions & 1 deletion capture-server/tests/common.rs
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,6 @@ impl EphemeralTopic {
impl Drop for EphemeralTopic {
fn drop(&mut self) {
debug!("dropping EphemeralTopic {}...", self.topic_name);
_ = self.consumer.unassign();
self.consumer.unsubscribe();
match futures::executor::block_on(timeout(
Duration::from_secs(10),
Expand Down

0 comments on commit 56dfe44

Please sign in to comment.