Support Questions
Find answers, ask questions, and share your expertise

Who agreed with this topic

Value error using Apache Nifi HBASE lookup

New Contributor

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

Who agreed with this topic