Zike Yang created STREAMPIPES-625:
-------------------------------------

             Summary: Refactor the Pulsar Protocol Adapter
                 Key: STREAMPIPES-625
                 URL: https://issues.apache.org/jira/browse/STREAMPIPES-625
             Project: StreamPipes
          Issue Type: Improvement
          Components: Connect
            Reporter: Zike Yang
            Assignee: Zike Yang


* {*}Implement SupportsRuntimeConfig{*}: Currenty, the pulsar adapter still 
implements the deprecated interface `ResolvesContainerProvidedOptions`. Need to 
implement SupportsRuntimeConfig.
 * *Add new setting `pulsar-subscription-name`:* Currently, the pulsar consumer 
uses the random subscription name, this can not ensure the data consistent for 
the users
 * {*}Refactor the adapter by using the asynchronous programming model{*}. 
Avoid using raw thread to handle the consumption.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to