[jira] [Commented] (FLINK-31428) Add user callbacks to PulsarSource and PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700359#comment-17700359 ] Alpha Diallo commented on FLINK-31428: -- Ok I see. Yes, the reason we added the factory is in case

[jira] [Commented] (FLINK-31428) Add user callbacks to PulsarSource and PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700177#comment-17700177 ] Alpha Diallo commented on FLINK-31428: -- We want to have access to both the value and the raw

[jira] [Updated] (FLINK-31428) Add user callbacks to PulsarSource and PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alpha Diallo updated FLINK-31428: - Description: We'd like to add support for user callbacks in {{PulsarSource}} and

[jira] [Created] (FLINK-31428) Add user callbacks to PulsarSource and PulsarSink

Alpha Diallo created FLINK-31428: Summary: Add user callbacks to PulsarSource and PulsarSink Key: FLINK-31428 URL: https://issues.apache.org/jira/browse/FLINK-31428 Project: Flink Issue