From 976d56d4d51440c25faa7cc8287a90cca7e634d1 Mon Sep 17 00:00:00 2001
From: Andrei Ionescu <webdev.andrei@gmail.com>
Date: Wed, 7 Aug 2024 17:44:03 +0300
Subject: [PATCH] Fix the char zero ending in native config

---
 src/consumer/stream_consumer.rs | 1 +
 1 file changed, 1 insertion(+)

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)