tree 28791d0f3147b18a4c22fc780c5efc4b6136736b
parent d8c623b10f2acdf18a3cd3a6ccabaad07d1f964a
author duli559 <554979476@qq.com> 1585220425 +0800
committer GitHub <noreply@github.com> 1585220425 +0800

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>