How to use HBase sink with Flume

I wanted to figure out how to use HBase as target for flume, so i created this sample configuration which reads events from netcat and writes them to HBase.

1. First step is to create test table in HBase with CF1 as column family. Everytime Flume gets a event it will write to HBase in test table in CF1 column family

   
   create 'test','CF1'
   

2. Create Flume configuration file that looks like this, I am using HBase sink with SimpleHbaseEventSerializer as Event Serializer. Note that i am assuming that this is unsecured cluster (Sandbox), but if you have secured cluster you should follow steps mentioned in Configure a Secure HBase Sink

   	agent1.sources = netcat1
   	agent1.sinks = hbase
   	agent1.channels =memory1
   	agent1.sources.netcat1.type = netcat
   	agent1.sources.netcat1.bind = localhost
   	agent1.sources.netcat1.port = 44444
   	agent1.sinks.hbase.type=hbase
   	agent1.sinks.hbase.table=test
   	agent1.sinks.hbase.columnFamily=CF1
   	agent1.sinks.hbase.serializer=org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
   	agent1.channels.memory1.type = memory
   	agent1.channels.memory1.capacity = 1000
   	agent1.channels.memory1.transactionCapacity = 100
   	agent1.sources.netcat1.channels = memory1
   	agent1.sinks.hbase.channel=memory1

   view raw netcat-hbase.properties hosted with ❤ by GitHub
3. Start the Flume server with the following command

   
   bin/flume-ng agent --conf conf --conf-file conf/netcat-hbase.properties --name agent1 -Dflume.root.logger=DEBUG,console
   

4. Now open the netcat client on port 44444 and send some messages to flume
   
5. If you query HBase test table, you should see the messages that were published to netcat