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 Aug 7, 2024
1 parent 52546d0 commit 5a25da2
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 @@ -209,6 +209,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 5a25da2

Please sign in to comment.