commit | 513940a5be4f87efe39366d14180a65dee08cfbc | [log] [tgz] |
---|---|---|
author | Sijie Guo <sijie@apache.org> | Tue Jun 18 02:36:44 2019 -0700 |
committer | GitHub <noreply@github.com> | Tue Jun 18 02:36:44 2019 -0700 |
tree | 3ba50e8dfde31c8d07dc35b05ee8ae0a015848d6 | |
parent | 7e8c0ea9a29fdeab8f0bc0d02a9258d3583f26ac [diff] |
[pulsar-kafka] Fix KafkaProducerInterceptorWrapper handles LongSerializer (#4549) *Motivation* KafkaProducerInterceptorWrapper uses a LongDeserializer for retrieve deserializer *Modifications* Fix the bug *Verify this change* Add unit test to cover the convertion