Associating a topic with regular table - KafkaJSONParser

KarthikMurugan

 

I'm trying to associate a topic with a regular table with KafkaJSONParser. My Kafka topic has a message as shown below and table has columns named "id" and "asset_name"

 

 

{
	"id": "2a925fd7138",
	"asset": {
		"name": "Device7"
	}
}

 

The column "id" is getting populated, but the column "asset_name" isn't. This could be due to the fact that after flatenning the JSON message, vertica is looking for a column named "asset.name", but its not a value column name.

 

If I'm not using Kafka and just FJSONParser, I could use underscore as the key separator by setting parser parameter key_separator to '_'. But this parameter is not supported in KafkaJSONParser. Any clues how to map the innser attribute "asset.name" to a regular Vertica table?