Member since
04-03-2018
2
Posts
0
Kudos Received
0
Solutions
04-04-2018
09:40 AM
@ahadjidj Hi Abdelkrim, I read your following post and I tried to do same steps. https://community.hortonworks.com/articles/138632/data-flow-enrichment-with-nifi-lookuprecord-proces.html do you have any idea about my issue? Thanks
... View more
04-03-2018
06:42 AM
Hi, We are evaluating apache Nifi for our realtime data needs. I created Nifi flow, which is consuming json data from kafka and the results are being sent to another kafka topic after enrichment. Problem: HbaseLookupService is using for enrichment. But the returned data is not expected value. I am sharing the output of my flow. We want to see value of "hbase_integid" as "123456789", but lookup service returns "MapRecord[{SERIAL_NUM=123456789}]", How can we extract only value of SERIAL_NUM value ("123456789")?? [ { "table" : "SIEBEL.S_ASSET", "op" : "Update", "hbase_integid" : "MapRecord[{SERIAL_NUM=123456789}]", "op_type" : "U", "op_ts" : "2018-04-02 05:48:35.055299", "current_ts" : "2018-04-02T08:48:40.071000", "pos" : "00000000020530642196", "before" : { "ROW_ID" : "1-G7B7EGF", "BILLACCT_ID" : null, "BILL_ACCNT_ID" : "1-G79GNWP", "BILL_PROFILE_ID" : "1-1FJHFB0", "INTEGRATION_ID" : "1-G79GU5K", "NAME" : null, "OWNER_ACCNT_ID" : "1-G79GEVV", "OWNER_CON_ID" : "1-G79GEW3", "PROD_ID" : "1-Q5B470", "PROMOTION_ID" : null, "PROM_INTEG_ID" : null, "PROM_ITEM_ID" : null, "PR_ACCNT_ID" : null, "PR_CON_ID" : "No Match Row Id", "ROOT_ASSET_ID" : "1-G7B7EFI", "SERIAL_NUM" : null, "X_VF_MSISDN" : null, "X_VF_PERMISSONS" : null }, "after" : { "ROW_ID" : "1-G7B7EGF", "BILLACCT_ID" : null, "BILL_ACCNT_ID" : null, "BILL_PROFILE_ID" : null, "INTEGRATION_ID" : null, "NAME" : null, "OWNER_ACCNT_ID" : null, "OWNER_CON_ID" : null, "PROD_ID" : null, "PROMOTION_ID" : null, "PROM_INTEG_ID" : null, "PROM_ITEM_ID" : null, "PR_ACCNT_ID" : null, "PR_CON_ID" : null, "ROOT_ASSET_ID" : null, "SERIAL_NUM" : null, "X_VF_MSISDN" : null, "X_VF_PERMISSONS" : null } } ] Thanks
... View more
Labels:
- Labels:
-
Apache NiFi