[FLINK-13701] KafkaTableSourceSink doesn't support topic pattern

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.8.1, 1.9.0
• Component/s: Connectors / Kafka, Table SQL / API
• Assignee: Unassigned
• Reporter: Shengnan YU
• Created: 13/Aug/19 07:47
• Updated: 13/Aug/19 08:26
• Resolved: 13/Aug/19 08:26

Description

The current KafkaTableSourceSink can only support single topic rather than multiple or topic patterns, which is limited in many cases.

.connect(
  new Kafka()
    .version("0.11")   
    .topic("...")     // Here we can only set single topic
)

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.

Issue Links

• is duplicated by: FLINK-13340 Add more Kafka topic option of flink-connector-kafka