Shengnan YU created FLINK-13701:
-----------------------------------
Summary: 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 / Hadoop Compatibility
Affects Versions: 1.8.1
Reporter: Shengnan YU
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)
