You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Apr 1, 2024. It is now read-only.
Original Issue: apache/pulsar#824636320048 Is your feature request related to a problem? Please describe.
Currently, flink pulsar consumer/producer can not read/write properties from/to Message, we hope to support it.
Describe the solution you'd like
A) For consumer,
change method deserialize(Message message)’ access level from private to proteced in class 'PulsarConsumerSource', and we can overrided it in derived class.
B) For producer,
add a method like following code, and we can overrided it in derived class. protected Map<String, String> generateProperties(IN value) { return new HashMap<>(); }
invoke TypedMessageBuilder.properties() method addtional in invoke(IN value, Context context) method at class 'FlinkPulsarProducer'.