You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2021/12/24 09:35:54 UTC
[pulsar-client-go] branch master updated: fix:add order key to message (#688)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new e03600f fix:add order key to message (#688)
e03600f is described below
commit e03600f28701c248d4841aa02715e4be1064a76c
Author: Lei Zhiyuan <le...@gmail.com>
AuthorDate: Fri Dec 24 17:34:57 2021 +0800
fix:add order key to message (#688)
Co-authored-by: zhiyuanlei <zh...@tencent.com>
fix:add order key to message
---
pulsar/consumer_partition.go | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
index 0b4e9fe..ecde0bf 100644
--- a/pulsar/consumer_partition.go
+++ b/pulsar/consumer_partition.go
@@ -551,6 +551,7 @@ func (pc *partitionConsumer) MessageReceived(response *pb.CommandMessage, header
replicatedFrom: msgMeta.GetReplicatedFrom(),
redeliveryCount: response.GetRedeliveryCount(),
encryptionContext: createEncryptionContext(msgMeta),
+ orderingKey: string(msgMeta.OrderingKey),
},
}
pc.queueCh <- messages
@@ -622,6 +623,7 @@ func (pc *partitionConsumer) MessageReceived(response *pb.CommandMessage, header
replicationClusters: msgMeta.GetReplicateTo(),
replicatedFrom: msgMeta.GetReplicatedFrom(),
redeliveryCount: response.GetRedeliveryCount(),
+ orderingKey: string(smm.OrderingKey),
}
} else {
msg = &message{