From 0c0faca4ea898930285372cd74efc7f4da732165 Mon Sep 17 00:00:00 2001 From: Inaiat Moraes Date: Sun, 5 Jan 2025 12:03:32 -0300 Subject: [PATCH] chore: fix fmt --- src/kafka/consumer/kafka_consumer.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/kafka/consumer/kafka_consumer.rs b/src/kafka/consumer/kafka_consumer.rs index fe4d7ec..3509aa8 100644 --- 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| {