Hello,
I’m trying to run a sample supervisor task in druid router UI but came across this error. I tried to check the schema but couldn’t find anything useful. Any ideas on why this might have occurred?
Error:
Failed to submit supervisor: Could not resolve type id ‘kafka’ into a subtype of [simple type, class org.apache.druid.indexing.overlord.supervisor.SupervisorSpec]: known type ids = [NoopSupervisorSpec, SupervisorSpec] at [Source: HttpInputOverHTTP@706c5335[c=770,q=0,[0]=null,s=STREAM]; line: 1, column: 2]
Spec:
{
“type”: “kafka” ,
“dataSchema” : {
“dataSource”: “metrics-kafka” ,
“parser” : {
“type”: “string” ,
“parseSpec” : {
“format”: “json” ,
“timestampSpec” : {
“column”: “timestamp” ,
“format”: “auto”
},
“dimensionsSpec” : {
“dimensions” : ,
“dimensionExclusions” : [
“timestamp” ,
“value”
]
}
}
},
“metricsSpec” : [
{
“name”: “count” ,
“type”: “count”
},
{
“name”: “value_sum” ,
“fieldName”: “value” ,
“type”: “doubleSum”
},
{
“name”: “value_min” ,
“fieldName”: “value” ,
“type”: “doubleMin”
},
{
“name”: “value_max” ,
“fieldName”: “value” ,
“type”: “doubleMax”
}
],
“granularitySpec” : {
“type”: “uniform” ,
“segmentGranularity”: “HOUR” ,
“queryGranularity”: “NONE”
}
},
“tuningConfig” : {
“type”: “kafka” ,
“maxRowsPerSegment”: 5000000
},
“ioConfig” : {
“topic”: “metrics” ,
“consumerProperties” : {
“bootstrap.servers”: “localhost:9092”
},
“taskCount”: 1 ,
“replicas”: 1 ,
“taskDuration”: “PT1H”
}
}
Thanks!