fix tests

PostHog · Dec 12, 2023 · 98507eb · 98507eb
1 parent 901286e
commit 98507eb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/capture-server/tests/common.rs b/capture-server/tests/common.rs
@@ -177,6 +177,7 @@ 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),