Skip to content

Commit 5a25da2

Browse files
Fix the char zero ending in native config
1 parent 52546d0 commit 5a25da2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/consumer/stream_consumer.rs

+1
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,7 @@ where
209209
let poll_interval = {
210210
let millis: u64 = native_config
211211
.get("max.poll.interval.ms")?
212+
.trim_end_matches(char::from(0))
212213
.parse()
213214
.expect("librdkafka validated config value is valid u64");
214215
Duration::from_millis(millis)

0 commit comments

Comments
 (0)