chore: fix fmt

inaiat · Jan 5, 2025 · 0c0faca · 0c0faca
1 parent 80378d6
commit 0c0faca
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/kafka/consumer/kafka_consumer.rs b/src/kafka/consumer/kafka_consumer.rs
@@ -186,10 +186,10 @@ impl KafkaConsumer {
   #[napi]
   pub async fn shutdown_consumer(&self) -> Result<()> {
     info!("Shutting down consumer - this will unsubscribe and stop the consumer from receiving messages");
-    
+
     // First unsubscribe from topics
     self.stream_consumer.unsubscribe();
-    
+
     // Then send shutdown signal
     let tx = self.shutdown_signal.0.clone();
     tx.send(()).map_err(|e| {