Skip to content

Commit 976d56d

Browse files
Fix the char zero ending in native config
1 parent 5079920 commit 976d56d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/consumer/stream_consumer.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -223,6 +223,7 @@ where
223223
let poll_interval = {
224224
let millis: u64 = native_config
225225
.get("max.poll.interval.ms")?
226+
.trim_end_matches(char::from(0))
226227
.parse()
227228
.expect("librdkafka validated config value is valid u64");
228229
Duration::from_millis(millis)

0 commit comments

Comments
 (0)