diff --git a/gstreamer-utils/src/streamproducer.rs b/gstreamer-utils/src/streamproducer.rs
index e0a9d8142..e2b3ca39f 100644
--- a/gstreamer-utils/src/streamproducer.rs
+++ b/gstreamer-utils/src/streamproducer.rs
@@ -349,6 +349,7 @@ impl StreamProducer {
                         .is_ok()
                         || latency_updated
                     {
+                        gst::info!(CAT, obj = appsink, "setting new latency: {latency}");
                         consumer.appsrc.set_latency(latency, gst::ClockTime::NONE);
                     }
                 }
@@ -626,6 +627,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
                 }