From a8e6f2ac5d2f321145e5cf66b332a6d05df092e4 Mon Sep 17 00:00:00 2001
From: xiaolongran <xiaolongran@tencent.com>
Date: Fri, 10 Dec 2021 14:39:12 +0800
Subject: [PATCH] Add properties filed for batch

Signed-off-by: xiaolongran <xiaolongran@tencent.com>
---
 pulsar/internal/batch_builder.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pulsar/internal/batch_builder.go b/pulsar/internal/batch_builder.go
index d08af537a5..7e4730421e 100644
--- a/pulsar/internal/batch_builder.go
+++ b/pulsar/internal/batch_builder.go
@@ -191,6 +191,7 @@ func (bc *batchContainer) Add(
 		bc.msgMetadata.ProducerName = &bc.producerName
 		bc.msgMetadata.ReplicateTo = replicateTo
 		bc.msgMetadata.PartitionKey = metadata.PartitionKey
+		bc.msgMetadata.Properties = metadata.Properties
 
 		if deliverAt.UnixNano() > 0 {
 			bc.msgMetadata.DeliverAtTime = proto.Int64(int64(TimestampMillis(deliverAt)))
@@ -211,6 +212,7 @@ func (bc *batchContainer) reset() {
 	bc.callbacks = []interface{}{}
 	bc.msgMetadata.ReplicateTo = nil
 	bc.msgMetadata.DeliverAtTime = nil
+	bc.msgMetadata.Properties = nil
 }
 
 // Flush all the messages buffered in the client and wait until all messages have been successfully persisted.