Jul 20, 2017 · 1 min read
Hi,
you need to use avro dataFormat and put your avro schema in dataSchema
"message": {
"dataFormat": "avro",
"dataSchema": "YOUR AVRO SCHEMA",
"fields": [
{
"name": "id",
"mapping": "id",
"type": "BIGINT"
},
{
"name": "id_str",
"mapping": "id_str",
"type": "VARCHAR"
},
{
"name": "user_name",
"mapping": "user/name",
"type": "VARCHAR"
}
]
}