Merge pull request #180 from scirner22/feature/producer-mutable-client

Mutable producer underlying client
kafka-rust · Aug 10, 2021 · 78d2316 · 78d2316
2 parents 9bea27b + 904bc39
commit 78d2316
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/producer.rs b/src/producer.rs
@@ -244,6 +244,11 @@ impl Producer {
         &self.client
     }
 
+    /// Borrows the underlying kafka client as mut.
+    pub fn client_mut(&mut self) -> &mut KafkaClient {
+        &mut self.client
+    }
+
     /// Destroys this producer returning the underlying kafka client.
     pub fn into_client(self) -> KafkaClient {
         self.client