fix crash when adjusting partition number

XiaoMi · Mar 15, 2023 · 80abc17 · 80abc17
1 parent 37e3e3f
commit 80abc17
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/producer/TalosProducer.go b/producer/TalosProducer.go
@@ -540,6 +540,8 @@ func (p *TalosProducer) DescribeTopicInfo() (*topic.TopicTalosResourceName, int3
 }
 
 func (c *TalosProducer) ProducerMonitorTask() {
+	c.producerLock.Lock()
+	defer c.producerLock.Unlock()
 	metrics := make([]*utils.FalconMetric, 0)
 	for _, p := range c.partitionSenderMap {
 		metrics = append(metrics, p.NewFalconMetrics()...)