clippy

SeaQL · Jul 6, 2024 · f236c81 · f236c81
1 parent 02b98a4
commit f236c81
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sea-streamer-kafka/src/producer.rs b/sea-streamer-kafka/src/producer.rs
@@ -138,7 +138,7 @@ impl KafkaProducer {
         K: rdkafka::message::ToBytes + ?Sized,
         P: rdkafka::message::ToBytes + ?Sized,
     {
-        let stream = StreamKey::new(record.topic.to_owned())?;
+        let stream = StreamKey::new(record.topic)?;
 
         let fut = self
             .get()