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)