ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer (#5955)
Fix #5934
Motivation
Support read/write properties from/to Message in flink pulsar consumer/producer, and you can override it in your derived class
Modifications
1. modify `PulsarConsumerSource.deserialize` access right from 'private' to 'protected'.
2. add method `protected Map<String, String> generateProperties(T value)` in class `FlinkPulsarProducer`, and invoked in `TypedMessageBuilder.properties()` to add it in pulsar Message.
* fix unit test failure
Co-authored-by: herodu <herodu@tencent.com>
Co-authored-by: Sijie Guo <sijie@apache.org>
Co-authored-by: duli <554979476@163.com>
7 files changed
