HBase

INSERT | UPSERT 
INTO <table_name> 
SELECT FIELD, ... 
FROM <kafka-topic> 
[PK FIELD, ...]

-- Insert mode, select all fields from topicA and write to tableA 
-- and use the default rowkey (topic name, partition, offset)
INSERT INTO tableA SELECT * FROM topicA

-- Insert mode, select 3 fields and rename from topicB 
-- use field y from the topic as the row key
INSERT INTO tableB SELECT x, y, z FROM topicB PK y

export CONNECTOR=hbase
docker-compose up -d hbase

docker exec -ti hbase /bin/bash

hbase shell 
create 'person',{NAME=>'lenses', VERSIONS=>1}

docker exec -ti hbase /bin/bash

<?xml version="1.0"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
<configuration>
  <property>
    <name>hbase.zookeeper.quorum</name>
    <value>hbase:2181</value>
  </property>
  <property>
    <name>hbase.zookeeper.property.clientPort</name>
    <value>2181</value>
  </property>
</configuration>

name=person-hbase
connector.class=com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector
tasks.max=1
topics=hbase
connect.hbase.column.family=lenses
connect.hbase.kcql=INSERT INTO person SELECT * FROM hbase PK firstName, lastName
connect.hbase.conf.dir=/

docker exec -ti fastdata /bin/bash

connect-cli create hbase < connector.properties

connect-cli create hbase < connector.properties

connect-cli status hbase

kafka-avro-console-producer \
  --broker-list localhost:9092 --topic rethink \
  --property value.schema='{"type":"record","name":"User","namespace":"com.datamountaineer.streamreactor.connect.rethink"
  ,"fields":[{"name":"firstName","type":"string"},{"name":"lastName","type":"string"},{"name":"age","type":"int"},{"name":"salary","type":"double"}]}'

{"firstName": "John", "lastName": "Smith", "age":30, "salary": 4830}

scan 'person'

docker-compose down