Fix formatting

influxdata · May 19, 2023 · 43cc6bd · 43cc6bd
1 parent d7b587f
commit 43cc6bd
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go
@@ -65,10 +65,10 @@ type KafkaConsumer struct {
 	ticker          *time.Ticker
 	fingerprint     string
 
-	parser      parsers.Parser
-	topicLock   sync.Mutex
-	wg          sync.WaitGroup
-	cancel      context.CancelFunc
+	parser    parsers.Parser
+	topicLock sync.Mutex
+	wg        sync.WaitGroup
+	cancel    context.CancelFunc
 }
 
 type ConsumerGroup interface {
@@ -202,7 +202,7 @@ func (k *KafkaConsumer) refreshTopics() error {
 
 	k.topicLock.Lock()
 	defer k.topicLock.Unlock()
-	
+
 	if len(k.regexps) == 0 {
 		return nil
 	}