[
https://issues.apache.org/jira/browse/FLINK-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-13701:
-----------------------------------
Component/s: (was: Connectors / Hadoop Compatibility)
Table SQL / API
Connectors / Kafka
> KafkaTableSourceSink doesn't support topic pattern
> --------------------------------------------------
>
> Key: FLINK-13701
> URL: https://issues.apache.org/jira/browse/FLINK-13701
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka, Table SQL / API
> Affects Versions: 1.8.1, 1.9.0
> Reporter: Shengnan YU
> Priority: Major
>
> The current KafkaTableSourceSink can only support single topic rather than
> multiple or topic patterns, which is limited in many cases.
> {code:java}
> .connect(
> new Kafka()
> .version("0.11")
> .topic("...") // Here we can only set single topic
> )
> {code}
> I lookup the source code of 1.9-release branch and there is no change. The
> new DDL feature is also related to the implementation of connectors. I think
> it is necessary to add topicPattern support.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)