Hi leo: Can you share why KafkaSource supports multiple topics? Why can't we use multiple sources and then union them?
Best, Jingsong Lee On Wed, Nov 27, 2019 at 8:19 AM leo <leozhangs...@qq.com> wrote: > Hi, > > As Flink does not own the data, so it can not forbid this. It's the > responsibility of user to deserialize messages from these topics with > custom schema deser. > > > On 11/26/19 10:55 AM, Jun Zhang wrote: > > > > If the data formats of the Multi-topics are different, what do you > > plan to do? > > > > On 11/26/2019 08:53，leo<leozhangs...@qq.com> > > <mailto:leozhangs...@qq.com> wrote： > > > > > > Hi, all. > > > > > > I want to propose an improvement of KafkaTableSource which can > > consume > > multiple topics at the same time. > > > > Here is proposal, > > https://issues.apache.org/jira/browse/FLINK-14729 > > > > > > Best, > > > > Leo > > > > > -- Best, Jingsong Lee
