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