谢谢，我明白了。
祝好
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hello
现在只支持一个topic里包含单张表的changelog，
你这个case相当于用了一个topic里包含多张表的changelog，只是twocol在解析binlog时 a,b
字段找不到，你配置ignore-parse-errors就会返回（null，null）
建议每张chagnelog表和一个topic对应就可以了
祝好
Leonard
> 在 2020年8月13日，19:55，LittleFall <1578166...@qq.com> 写道：
>
> 这是我在 flink sql 中建立的两张表：
> create table base (
>id
这是我在 flink sql 中建立的两张表：
create table base (
id int,
location varchar(20)
)WITH (
'connector' = 'kafka',
'topic' = 'example',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'latest-offset',
'properties.bootstrap.servers' = 'localhost:9092',
