ड्र्यूड काफ्का अनुक्रमण सेवा सेटअप-json, अपाचे-काफ्का, ड्र्यूड

मैंने डॉक्स का अनुसरण किया और संपादित किया:

druid-0.9.2/conf/druid/_common/common.runtime.properties

और जोड़ा:

"druid-kafka-indexing-service"

को druid.extensions.loadList और सभी कठोर सेवाओं को फिर से शुरू किया: middlemanager, overlord, coordinator, broker, historical

मैं भागा:

curl -X "POST" -H "Content-Type:application/json" -d @kafka_connect/script.json druid_server:8090/druid/indexer/v1/task

लेकिन मिल गया:

{"error":"Could not resolve type id "kafka" into a subtype of [simple type, class io.druid.indexing.common.task.Task]n at [Source: HttpInputOverHTTP@4c467f1c; line: 1, column: 4]"}

इनपुट json है:

{
"type": "kafka",
"dataSchema": {
"dataSource": "sensors-kafka",
"parser": {
"type": "string",
"parseSpec": {
"format": "json",
"timestampSpec": {
"column": "timestamp",
"format": "auto"
},
"dimensionsSpec": {
"dimensions": ["machine", "key"],
"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": "sensor",
"consumerProperties": {
"bootstrap.servers": "kafka_server:2181"
},
"taskCount": 1,
"replicas": 1,
"taskDuration": "PT1H"
}
}

किसी भी विचार मैंने क्या गलत किया? डॉक्टर के अनुसार: http://druid.io/docs/0.9.2-rc3/development/extensions-core/kafka-ingestion.html, द type है kafka?

क्या यह जांचने का कोई तरीका है कि एक्सटेंशन ठीक से लोड किया गया था या मुझे प्रत्येक घटक में एक्सटेंशन को निर्दिष्ट करना होगा runtime.properties?

उत्तर:

जवाब के लिए 2 № 1

पर्यवेक्षकों जोंस ऐनक को इस समापन बिंदु पर अधिपति पर भेजा जाना है /druid/indexer/v1/supervisor

curl -X POST -H "Content-Type: application/json" -d @kafka_connect/script.json http://druid_server:8090/druid/indexer/v1/supervisor

---

जवाब के लिए 0 № 2

मैं इसी तरह की समस्याओं से मिलता हूं, और मैंने इसे ठीक कर दिया"druid.extensions.loadList" में "druid-kafka-indexing-service" जोड़कर "conf / druid / _common / common.runtime.properties" की फ़ाइल को संशोधित करें, और अब इसके लिए इसका प्रदर्शन करें:

druid.extensions.loadList=["druid-parser-route", "mysql-metadata-storage", "druid-kafka-indexing-service"]

आशा किसी और की मदद कर सकती है

---