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	Description
`hbaseConfigResources`	String	None	false	HBase system configuration `hbase-site.xml` file.
`zookeeperQuorum`	String	None	true	HBase system configuration about `hbase.zookeeper.quorum` value.
`zookeeperClientPort`	String	2181	false	HBase system configuration about `hbase.zookeeper.property.clientPort` value.
`zookeeperZnodeParent`	String	/hbase	false	HBase system configuration about `zookeeper.znode.parent` value.
`tableName`	None	String	true	HBase table, the value is `namespace:tableName`.
`rowKeyName`	String	None	true	HBase table rowkey name.
`familyName`	String	None	true	HBase table column family name.
`qualifierNames`	String	None	true	HBase table column qualifier names.
`batchTimeMs`	Long	1000l	false	HBase table operation timeout in milliseconds.
`batchSize`	int	200	false	Batch size of updates made to the HBase table.

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']