Skip to content

Commit

Permalink
Fix the char zero ending in native config
Browse files Browse the repository at this point in the history
  • Loading branch information
andrei-ionescu committed Dec 10, 2024
1 parent 5079920 commit 976d56d
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/consumer/stream_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 976d56d

Please sign in to comment.