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
