드루이드는 카프카의 인덱싱 서비스 설정은

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

typekafka는 무엇입니까?

확장이 제대로로드 아니면 각 구성 요소의 runtime.properties

감사의 확장자를 지정해야 할 것을 확인하는 방법은 무엇입니까

사양은 감독자의 JSON이에이 엔드 포인트에 전송 될

Answer 1

오류가 군주로 해결할 수없는 카프카 같은 것으로 변경 한 경우

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