Bytes Format

直接使用byte[]类型

用例

CREATE TABLE mysql_binlog (
 log BINARY
) WITH (
 'connector' = 'kafka',
  'topic' = 'test_filter',
  'properties.bootstrap.servers' = 'localhost:9292',
  'properties.group.id' = 'testGroup1',
  'scan.startup.mode' = 'latest-offset',
  'format' = 'bytes'
);

create table print_table (
    log BINARY
) WITH (
 'connector' = 'kafka',
  'topic' = 'test_2sink',
  'properties.bootstrap.servers' = 'localhost:9292',
  'properties.group.id' = 'testGroup1',
  'scan.startup.mode' = 'latest-offset',
  'format' = 'bytes'
);

insert into print_table select * from mysql_binlog;