We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb4270c commit 76148d2Copy full SHA for 76148d2
src/producer/base_producer.rs
@@ -456,7 +456,10 @@ where
456
}
457
let (payload_ptr, payload_len) = as_bytes(record.payload);
458
let (key_ptr, key_len) = as_bytes(record.key);
459
- let topic_cstring = CString::new(record.topic).unwrap();
+ let topic_cstring = match CString::new(record.topic) {
460
+ Ok(topic) => topic,
461
+ Err(nul_error) => return Err((nul_error.into(), record)),
462
+ };
463
let opaque_ptr = record.delivery_opaque.into_ptr();
464
let produce_error = unsafe {
465
rdsys::rd_kafka_producev(
0 commit comments