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)
Attachments
Issue Links
- links to
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)