ドルイドのカフカインデックスサービスのセットアップ

Question

私はドキュメントを踏襲して編集：

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

、コメントを追加しました：druid.extensions.loadListへ

"druid-kafka-indexing-service" 

をし、すべてのドルイドのサービスを再起動：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ですか？

拡張子が正しくロードされたか、私は上司のJSONの仕様は上のこのエンドポイントに送信される各コンポーネントのruntime.properties

おかげ

Answer 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