Re: How to insert Json records from Flume into Hbase with Kafka source

2020-02-16 Thread Mich Talebzadeh
BTW When I turn out headers in the conf fle JsonAgent.sinks.Hbase-sink.serializer.depositHeaders=true I get {"rowkey":"f8a6e006-35bb-4470-9a7b-9273b8aa83f1" *column=PRICE_INFO:key*, timestamp=1581849565330, *value=f8a6e006-35bb-4470-9a7b-9273b8aa83f*1 {"rowkey":"f8a6e006-35bb-4470-9a7b-9273b8

Re: How to insert Json records from Flume into Hbase with Kafka source

2020-02-16 Thread Mich Talebzadeh
Hi, This regex seems to work *JsonAgent.sinks.Hbase-sink.serializer.regex =[^_]*"(.+).{1},(.+),(.+),(.+).{1}* Remember we were getting the below as ROW (incorrect) beforehand {"rowkey":"eff0bdc7-d6b1-40b5-ad0a-b8181173b806" The first positional column is the ROW_KEY. *We need to strip all exce