Hi, 你的附件好像没有上传。 On Mon, 27 Jul 2020 at 18:17, air23 <wangfei23_...@163.com> wrote:
> *你好。这个是我的解析sql。我想读取binlog的 data数据和table 数据。 为什么可以取到table 不能取到data呢?* > > private static final String KAFKA_SQL = "CREATE TABLE kafkaTable (\n" + > " `data` VARCHAR , " + > " `table` VARCHAR " + > ") WITH (" + > " 'connector' = 'kafka'," + > " 'topic' = 'order_source'," + > " 'properties.bootstrap.servers' = '***'," + > " 'properties.group.id' = 'real1'," + > " 'format' = 'json'," + > " 'scan.startup.mode' = 'earliest-offset'" + > ")"; > > > 具体见附件 有打印 > > > > >