diff --git a/gstreamer-utils/src/streamproducer.rs b/gstreamer-utils/src/streamproducer.rs
index 1b89c64c6..c57b66ed0 100644
--- a/gstreamer-utils/src/streamproducer.rs
+++ b/gstreamer-utils/src/streamproducer.rs
@@ -327,6 +327,7 @@ impl StreamProducer {
                         .is_ok()
                         || latency_updated
                     {
+                        gst::info!(CAT, obj: appsink, "setting new latency: {latency}");
                         consumer.appsrc.set_latency(latency, gst::ClockTime::NONE);
                     }
                 }
@@ -562,6 +563,7 @@ impl<'a> From<&'a gst_app::AppSink> for StreamProducer {
                 let latency = event.latency();
                 let mut consumers = consumers.lock().unwrap();
                 consumers.current_latency = Some(latency);
+                consumers.latency_updated = true;
 
                 gst::PadProbeReturn::Ok
             }),