[druid-user] issue with druid and kafka with avro schema

I am having an issue with druid pointing at kafka with an avro schema the spec is accepted and runs

but no processed or processed with error or thrown away and the data source is not established

The config follows:

{
“spec”: {
“type”: “kafka”,
“dataSchema”: {
“dataSource”: “opensky”,
“timestampSpec”: {
“column”: “timestamp”,
“format”: “auto”
},
“dimensionsSpec”: {
“dimensions”: [
{
“name”: “view”,
“type”: “string”
}
],
“dimensionExclusions”:
},
“metricsSpec”: ,
“parser”: {
“type”: “avro_stream”,
“avroBytesDecoder”: {
“type”: “schema_registry”,
“url”: “schema_registry:8081”,
“capacity”: 100
},
“parseSpec”: {
“format”: “avro”,
“flattenSpec”: {
“useFieldDiscovery”: true,
“fields”: [
{
“type”: “path”,
“name”: “timestamp”,
“expr”: “$.timestamp”
}
]
}
}
},
“granularitySpec”: {
“type”: “uniform”,
“segmentGranularity”: “hour”,
“queryGranularity”: “NONE”,
“rollup”: false
}
},
“ioConfig”: {
“topic”: “avro-test”,
“useEarliestOffset”: true,
“consumerProperties”: {
“bootstrap.servers”: “broker:9092”
},
“type”: “kafka”
},
“tuningConfig”: {
“type”: “kafka”,
“reportParseExceptions”: true
}
},
“type”: “kafka”
}