You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/12/30 04:38:57 UTC
[GitHub] [pulsar] duli559 opened a new pull request #5954: ISSUE-5934:
Support read/write properties from/to Message in flink pulsar
consumer/producer
duli559 opened a new pull request #5954: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer
URL: https://github.com/apache/pulsar/pull/5954
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'.
add method `protected Map<String, String> generateProperties(T value)` in class `FlinkPulsarProducer`, and invoked in [TypedMessageBuilder.properties](url) to add it in pulsar Message.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] duli559 opened a new pull request #5954: ISSUE-5934:
Support read/write properties from/to Message in flink pulsar
consumer/producer
Posted by GitBox <gi...@apache.org>.
duli559 opened a new pull request #5954: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer
URL: https://github.com/apache/pulsar/pull/5954
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.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] duli559 closed pull request #5954: ISSUE-5934: Support
read/write properties from/to Message in flink pulsar consumer/producer
Posted by GitBox <gi...@apache.org>.
duli559 closed pull request #5954: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer
URL: https://github.com/apache/pulsar/pull/5954
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] duli559 closed pull request #5954: ISSUE-5934: Support
read/write properties from/to Message in flink pulsar consumer/producer
Posted by GitBox <gi...@apache.org>.
duli559 closed pull request #5954: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer
URL: https://github.com/apache/pulsar/pull/5954
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services