[issue 490] Add error log when schema encode failed. (apache#571)

* Add error log when schema encode failed. * format code
Fanatics · Jul 21, 2021 · bbee640 · bbee640
1 parent 1dfb8fd
commit bbee640
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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
 		}
 	}