diff --git a/src/consumer/stream_consumer.rs b/src/consumer/stream_consumer.rs
index 5a7f60552..36934e62c 100644
--- a/src/consumer/stream_consumer.rs
+++ b/src/consumer/stream_consumer.rs
@@ -210,7 +210,7 @@ where
             let millis: u64 = native_config
                 .get("max.poll.interval.ms")?
                 .parse()
-                .expect("librdkafka validated config value is valid u64");
+                .unwrap_or(300000);
             Duration::from_millis(millis)
         };