Options

Associating a topic with regular table - KafkaJSONParser

 

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?

 

Leave a Comment

BoldItalicStrikethroughOrdered listUnordered list
Emoji
Image
Align leftAlign centerAlign rightToggle HTML viewToggle full pageToggle lights
Drop image/file