diff --git a/src/consumer/stream_consumer.rs b/src/consumer/stream_consumer.rs
index 12aa8ee99..d27b2e810 100644
--- a/src/consumer/stream_consumer.rs
+++ b/src/consumer/stream_consumer.rs
@@ -223,6 +223,7 @@ where
         let poll_interval = {
             let millis: u64 = native_config
                 .get("max.poll.interval.ms")?
+                .trim_end_matches(char::from(0))
                 .parse()
                 .expect("librdkafka validated config value is valid u64");
             Duration::from_millis(millis)