HBase sink connector

The HBase sink connector pulls the messages from Pulsar topics and persists the messages to HBase tables

Configuration

The configuration of the HBase sink connector has the following properties.

Property

Name	Type	Default	Required
hbaseConfigResources	String	None	false
zookeeperQuorum	String	None	true
zookeeperClientPort	String	2181	false
zookeeperZnodeParent	String	/hbase	false
tableName	None	String	true
rowKeyName	String	None	true
familyName	String	None	true
qualifierNames	String	None	true
batchTimeMs	Long	1000l	false
batchSize	int	200	false

Example

Before using the HBase sink connector, you need to create a configuration file through one of the following methods.

• JSON

  
  {
      "hbaseConfigResources": "hbase-site.xml",
      "zookeeperQuorum": "localhost",
      "zookeeperClientPort": "2181",
      "zookeeperZnodeParent": "/hbase",
      "tableName": "pulsar_hbase",
      "rowKeyName": "rowKey",
      "familyName": "info",
      "qualifierNames": [ 'name', 'address', 'age']
  }
  

• YAML

  
  configs:
      hbaseConfigResources: "hbase-site.xml"
      zookeeperQuorum: "localhost"
      zookeeperClientPort: "2181"
      zookeeperZnodeParent: "/hbase"
      tableName: "pulsar_hbase"
      rowKeyName: "rowKey"
      familyName: "info"
      qualifierNames: [ 'name', 'address', 'age']