[pulsar-client-go] branch master updated: [issue 490] Add error log when schema encode failed. (#571)

[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 bbee640  [issue 490] Add error log when schema encode failed. (#571)
bbee640 is described below

commit bbee6401ac34ae1d8ca5f08e8990418c69aa52e5
Author: Zhiqiang Li <stu...@qq.com>
AuthorDate: Wed Jul 21 18:41:03 2021 +0800

    [issue 490] Add error log when schema encode failed. (#571)
    
    * Add error log when schema encode failed.
    
    * format code
---
 pulsar/producer_partition.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index 7e83bfa..abec4fc 100644
--- a/pulsar/producer_partition.go
+++ b/pulsar/producer_partition.go
@@ -356,6 +356,7 @@ func (p *partitionProducer) internalSend(request 
*sendRequest) {
        if p.options.Schema != nil {
                schemaPayload, err = p.options.Schema.Encode(msg.Value)
                if err != nil {
+                       p.log.WithError(err).Errorf("Schema encode message 
failed %s", msg.Value)
                        return
                }
        }