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
