Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
mlowicki committed Jun 23, 2023
1 parent 92c1f24 commit 5d1c3d4
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/producer/base_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -224,8 +224,7 @@ unsafe extern "C" fn partitioner_cb<Part: Partitioner, C: ProducerContext<Part>>
let topic_name = CStr::from_ptr(rdsys::rd_kafka_topic_name(topic));
let topic_name = str::from_utf8_unchecked(topic_name.to_bytes());

let is_partition_available =
|p: i32| { rdsys::rd_kafka_topic_partition_available(topic, p) == 1 };
let is_partition_available = |p: i32| rdsys::rd_kafka_topic_partition_available(topic, p) == 1;

let key = if keydata.is_null() {
None
Expand Down

0 comments on commit 5d1c3d4

Please sign in to comment.