fixed some typoe

Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>
axfor · Mar 18, 2023 · 1556879 · 1556879
1 parent 28dc496
commit 1556879
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/cmd/ingester/app/consumer/consumer.go b/cmd/ingester/app/consumer/consumer.go
@@ -78,10 +78,10 @@ func (c *Consumer) Start() {
 	c.cancel = cancel
 	c.doneWg.Add(1)
 
-	var firstStart sync.WaitGroup
-	firstStart.Add(1)
+	var fristStart sync.WaitGroup
+	fristStart.Add(1)
 	go func() {
-		firstStart.Done()
+		fristStart.Done()
 		defer c.doneWg.Done()
 		for {
 			select {
@@ -96,7 +96,7 @@ func (c *Consumer) Start() {
 			}
 		}
 	}()
-	firstStart.Wait()
+	fristStart.Wait()
 }
 
 // Close closes the Consumer and underlying sarama consumer