diff --git a/gstreamer-utils/src/streamproducer.rs b/gstreamer-utils/src/streamproducer.rs
index 6b8f34c81..d00a984d7 100644
--- a/gstreamer-utils/src/streamproducer.rs
+++ b/gstreamer-utils/src/streamproducer.rs
@@ -102,6 +102,7 @@ impl StreamProducer {
             .is_some()
         {
             gst::debug!(CAT, obj: &self.appsink, "Removed consumer {} ({:?})", name, consumer);
+            consumer.set_callbacks(gst_app::AppSrcCallbacks::builder().build());
         } else {
             gst::debug!(CAT, obj: &self.appsink, "Consumer {} ({:?}) not found", name, consumer);
         }