This project replicates RocketMQ topics to HBase tables.
Have the below properties set in rocketmq_hbase.conf
| key | nullable | default | description |
|---|---|---|---|
| topics | false | A comma separated list of RocketMQ topics to replicate to HBase (e.g., topic1,topic2,topic3) | |
| nameserver | true | localhost:9876 | RocketMQ name server address |
| consumerGroup | true | HBASE_CONSUMER_GROUP | The consumer group name |
| messageModel | true | BROADCASTING | RocketMQ message model, ‘BROADCASTING’ or ‘CLUSTERING’ |
| zookeeperAddress | true | localhost | A comma separated list of the IP addresses of all ZooKeeper servers in the cluster |
| zookeeperPort | true | 2181 | The port at which the clients will connect |
| batchSize | true | 32 | The maximum number of messages to be consumed in batch from RocketMQ |
| pullInterval | true | 1000 | Time in milliseconds to wait between consecutive pulls |