Update kafka message pool to avoid unnecessary heap allocation

Trendyol · Jan 6, 2023 · c03e6a6 · c03e6a6
1 parent dec1325
commit c03e6a6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka/producer/producer_batch.go b/kafka/producer/producer_batch.go
@@ -61,6 +61,7 @@ func (b *producerBatch) StartBatch() {
 
 			case message := <-b.messageChn:
 				b.messages = append(b.messages, *message)
+				KafkaMessagePool.Put(message)
 				if len(b.messages) == b.batchLimit {
 					err := b.FlushMessages()
 					if err != nil {