[BEAM-3170] support topicPartition in BeamKafkaTable

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.3.0
• Component/s: dsl-sql
• Assignee: Mingmin Xu
• Reporter: Mingmin Xu
• Created: 10/Nov/17 18:29
• Updated: 24/Jul/20 20:11
• Resolved: 13/Nov/17 08:14

Description

In KafkaIO there're two options to set the source topics/partitions, and we only support the 1st one now:

1 .withTopics(topics)
2. withTopicPartitions(topicPartitions)

Issue Links

• links to: GitHub Pull Request #4115