Revert "revert rdkafka to 0.34 to evaluate impact (#68)"

This reverts commit f714f32.
PostHog · Dec 13, 2023 · 08a245e · 08a245e
1 parent 1a7e87a
commit 08a245e
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 7 deletions.
diff --git a/.github/workflows/rust.yml b/.github/workflows/rust.yml
@@ -35,7 +35,6 @@ jobs:
 
   test:
     runs-on: buildjet-4vcpu-ubuntu-2204
-    timeout-minutes: 10
 
     steps:
     - uses: actions/checkout@v3

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -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"

diff --git a/capture-server/tests/common.rs b/capture-server/tests/common.rs
@@ -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),