[pulsar-client-go] branch master updated: fix:add order key to message (#688)

[rxl]

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 <leizhiy...@gmail.com>
AuthorDate: Fri Dec 24 17:34:57 2021 +0800

    fix:add order key to message (#688)
    
    Co-authored-by: zhiyuanlei <zhiyuan...@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{