删除不需要的导致空指针的锁

eolinker · Apr 3, 2023 · a55c106 · a55c106
1 parent 27a9313
commit a55c106
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/drivers/output/kafka/producer.go b/drivers/output/kafka/producer.go
@@ -21,7 +21,6 @@ type tProducer struct {
 	conf      *ProducerConfig
 	cancel    context.CancelFunc
 	enable    bool
-	locker    *sync.Mutex
 	formatter eosc.IFormatter
 }
 
@@ -101,9 +100,9 @@ func (o *tProducer) write(msg *sarama.ProducerMessage) {
 	if !o.enable {
 		return
 	}
-	o.locker.Lock()
+
 	o.input <- msg
-	o.locker.Unlock()
+
 }
 
 func (o *tProducer) work() {