Fix getting message channel instead of channel

Trendyol · Jan 6, 2023 · 8d445a7 · 8d445a7
1 parent c03e6a6
commit 8d445a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/producer/producer_batch.go b/kafka/producer/producer_batch.go
@@ -74,7 +74,7 @@ func (b *producerBatch) StartBatch() {
 }
 
 func (b *producerBatch) FlushMessages() error {
-	messageCount := len(b.messageChn)
+	messageCount := len(b.messages)
 	if messageCount == 0 {
 		return nil
 	}