diff --git a/gstreamer-audio/src/audio_decoder.rs b/gstreamer-audio/src/audio_decoder.rs
index 429200e10..ed27ef1b4 100644
--- a/gstreamer-audio/src/audio_decoder.rs
+++ b/gstreamer-audio/src/audio_decoder.rs
@@ -49,7 +49,7 @@ pub trait AudioDecoderExtManual: 'static {
 
     fn set_output_format(&self, info: &AudioInfo) -> Result<(), gst::FlowError>;
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams);
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams);
 
     #[allow(clippy::too_many_arguments)]
     fn error<T: gst::MessageErrorDomain>(
@@ -136,7 +136,7 @@ impl<O: IsA<AudioDecoder>> AudioDecoderExtManual for O {
         }
     }
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams) {
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams) {
         unsafe {
             let mut allocator = ptr::null_mut();
             let mut params = mem::zeroed();
diff --git a/gstreamer-audio/src/audio_encoder.rs b/gstreamer-audio/src/audio_encoder.rs
index 4fa5144cd..8dd8522c0 100644
--- a/gstreamer-audio/src/audio_encoder.rs
+++ b/gstreamer-audio/src/audio_encoder.rs
@@ -25,7 +25,7 @@ pub trait AudioEncoderExtManual: 'static {
 
     fn set_output_format(&self, caps: &gst::Caps) -> Result<(), gst::FlowError>;
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams);
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams);
 
     fn get_latency(&self) -> (gst::ClockTime, gst::ClockTime);
 }
@@ -73,7 +73,7 @@ impl<O: IsA<AudioEncoder>> AudioEncoderExtManual for O {
         }
     }
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams) {
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams) {
         unsafe {
             let mut allocator = ptr::null_mut();
             let mut params = mem::zeroed();
diff --git a/gstreamer-video/src/video_decoder.rs b/gstreamer-video/src/video_decoder.rs
index fe29f3faf..3fe7aabdd 100644
--- a/gstreamer-video/src/video_decoder.rs
+++ b/gstreamer-video/src/video_decoder.rs
@@ -47,7 +47,7 @@ pub trait VideoDecoderExtManual: 'static {
     fn get_frames(&self) -> Vec<VideoCodecFrame>;
     fn get_oldest_frame(&self) -> Option<VideoCodecFrame>;
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams);
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams);
 
     fn have_frame(&self) -> Result<gst::FlowSuccess, gst::FlowError>;
     fn finish_frame(&self, frame: VideoCodecFrame) -> Result<gst::FlowSuccess, gst::FlowError>;
@@ -113,7 +113,7 @@ impl<O: IsA<VideoDecoder>> VideoDecoderExtManual for O {
         ret.into_result()
     }
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams) {
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams) {
         unsafe {
             let mut allocator = ptr::null_mut();
             let mut params = mem::zeroed();
diff --git a/gstreamer-video/src/video_encoder.rs b/gstreamer-video/src/video_encoder.rs
index 4aa05869b..b315d5db0 100644
--- a/gstreamer-video/src/video_encoder.rs
+++ b/gstreamer-video/src/video_encoder.rs
@@ -31,7 +31,7 @@ pub trait VideoEncoderExtManual: 'static {
     fn get_frames(&self) -> Vec<VideoCodecFrame>;
     fn get_oldest_frame(&self) -> Option<VideoCodecFrame>;
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams);
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams);
 
     fn finish_frame(
         &self,
@@ -71,7 +71,7 @@ impl<O: IsA<VideoEncoder>> VideoEncoderExtManual for O {
         ret.into_result()
     }
 
-    fn get_allocator(&self) -> (gst::Allocator, gst::AllocationParams) {
+    fn get_allocator(&self) -> (Option<gst::Allocator>, gst::AllocationParams) {
         unsafe {
             let mut allocator = ptr::null_mut();
             let mut params = mem::zeroed();