| commit | bbee6401ac34ae1d8ca5f08e8990418c69aa52e5 | [log] [tgz] |
|---|---|---|
| author | Zhiqiang Li <stulzq@qq.com> | Wed Jul 21 18:41:03 2021 +0800 |
| committer | GitHub <noreply@github.com> | Wed Jul 21 18:41:03 2021 +0800 |
| tree | 4268463c73b3a5cadfc00c5078cd5a3d826b3c55 | |
| parent | 1dfb8fdffb97d0c4f4845cc668bed485324daf5c [diff] |
[issue 490] Add error log when schema encode failed. (#571) * Add error log when schema encode failed. * format code
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 @@ 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 } }