[fix][issue 1098] check batchBuilder in case batch is disabled (#1099)

apache · Nov 1, 2023 · 0845e73 · 0845e73
1 parent 620ecf4
commit 0845e73
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -724,6 +724,13 @@ type pendingItem struct {
 }
 
 func (p *partitionProducer) internalFlushCurrentBatch() {
+	if p.batchBuilder == nil {
+		// batch is not enabled
+		// the batch flush ticker should be stopped but it might still called once
+		// depends on when stop() is called concurrently
+		// so we add check to prevent the flow continues on a nil batchBuilder
+		return
+	}
 	if p.batchBuilder.IsMultiBatches() {
 		p.internalFlushCurrentBatches()
 		return