FlinkServer对接多套互信HBase集群

1、创建任务如下：

create table datagen1(uuid INT, name VARCHAR(10), age INT) WITH(
  'connector' = 'datagen',
  'rows-per-second' = '2',
  'fields.uuid.kind' = 'sequence',
  'fields.uuid.start' = '100100',
  'fields.uuid.end' = '100200',
  'fields.name.length' = '10',
  'fields.age.min' = '1',
  'fields.age.max' = '100'
);
CREATE TABLE hbasesink1 (
  rowkey STRING,
  f1 ROW < name STRING,
  age INT >,
  PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
  'connector' = 'hbase-2.2',
  'table-name' = 'default:hbase_sink',
  'zookeeper.quorum' = 'A集群quorum地址:24002',
  'properties.hbase.regionserver.kerberos.principal' = 'hbase/hadoop.zsc_bdp_zjrcu@ZSC_BDP_ZJRCU',
  'properties.hbase.master.kerberos.principal' = 'hbase/hadoop.zsc_bdp_zjrcu@ZSC_BDP_ZJRCU',
  'properties.hbase.rpc.protection' = 'authentication',
  'properties.zookeeper.znode.parent' = '/hbase',
  'properties.hbase.security.authorization' = 'true',
  'properties.hbase.security.authentication' = 'kerberos'
);
CREATE TABLE hbasesink2 (
  rowkey STRING,
  f1 ROW < name STRING,
  age INT >,
  PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
  'connector' = 'hbase-2.2',
  'table-name' = 'default:hbase_sink',
  'zookeeper.quorum' = 'B集群quorum地址:24002',
  'properties.hbase.regionserver.kerberos.principal' = 'hbase/hadoop.cs_bdp_zjrcu@CS_BDP_ZJRCU',
  'properties.hbase.master.kerberos.principal' = 'hbase/hadoop.cs_bdp_zjrcu@CS_BDP_ZJRCU',
  'properties.hbase.rpc.protection' = 'authentication',
  'properties.zookeeper.znode.parent' = '/hbase',
  'properties.hbase.security.authorization' = 'true',
  'properties.hbase.security.authentication' = 'kerberos'
);
insert into
  hbasesink1
select
  concat('rowkey_', cast(uuid as STRING)) as rowkey,
  ROW(name, age) as f1
from
  datagen1;
insert into
  hbasesink2
select
  concat('rowkey_', cast(uuid as STRING)) as rowkey,
  ROW(name, age) as f1
from
  datagen1;

2、数据写入情况验证

A集群写入情况B集群写入情况