[
https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463115#comment-17463115
]
Martijn Visser commented on FLINK-25380:
----------------------------------------
[~nicholasjiang] [~RocMarshal] Since we want to deprecate the old
SourceFunction and SinkFunction (which is where the legacy RMQSource and
RMQSink rely on), we should not add new code before we take care of this
refactoring. It only increases technical debt.
> Introduce DynamicTableSink & DynamicTableSource for RabbitMQ
> ------------------------------------------------------------
>
> Key: FLINK-25380
> URL: https://issues.apache.org/jira/browse/FLINK-25380
> Project: Flink
> Issue Type: New Feature
> Components: Connectors/ RabbitMQ
> Reporter: RocMarshal
> Priority: Minor
>
> This feature should be arranged afterÂ
> # FLINK-21373
> # FLINK-20628
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
