I have a fanning out operation where I have one source and and based on the
event headers (headers are added from the source input), I would like to
channel the event to different Hbase tables. I am using the same
serializer for the hbase tables.
I have created different channels, one for each sink. Also, I have put the
selector tag in the configuration file to select based on the header values.
The only thing I have not added is the interceptor. I think I don't need
to use the interceptor to add any header information because the header
value is already there as the data comes from the avro source.
However, I am not able correctly channel the events to different tables.
Anybody has any suggestions ?