summaryrefslogtreecommitdiffstats
path: root/components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm
diff options
context:
space:
mode:
authorGuobiao Mo <guobiaomo@chinamobile.com>2019-03-28 14:37:41 -0700
committerGuobiao Mo <guobiaomo@chinamobile.com>2019-03-29 16:03:09 -0700
commit3cb79e621ef9982d039d3770fbe02a0bed208481 (patch)
treeafea2c7bf5c460d36e1a1a996c02861138700040 /components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm
parent84066f315a1692ddfe9caab607c438e884c31cc6 (diff)
Unit test for seed code
This project depends heavily on outside infrastructure, thus there are not much unit test cases. Issue-ID: DCAEGEN2-1309 Change-Id: I8893f4029014673139e67bf373fd77e9e5c42f83 Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
Diffstat (limited to 'components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm')
-rw-r--r--components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm57
1 files changed, 57 insertions, 0 deletions
diff --git a/components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm b/components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm
new file mode 100644
index 00000000..01ebaf2e
--- /dev/null
+++ b/components/datalake-handler/feeder/src/main/resources/druid/kafka-supervisor-template.vm
@@ -0,0 +1,57 @@
+{
+ "type": "kafka",
+ "dataSchema": {
+ "dataSource": "$topic",
+ "parser": {
+ "type": "string",
+ "parseSpec": {
+ "format": "json",
+ "flattenSpec": {
+ "useFieldDiscovery": false,
+ "fields": [
+ #foreach($flatten in $dimensions)
+
+ {
+"type": "path",
+"name": "$flatten[0]",
+"expr": "$flatten[1]"
+},
+ #end
+ ]
+ },
+ "timestampSpec": {
+ "column": "$timestamp",
+ "format": "$timestampFormat"
+ },
+ "dimensionsSpec": {
+ "dimensions": [
+ ],
+ "dimensionsExclusions": [
+ ]
+ }
+ }
+ },
+ "metricsSpec": [],
+ "granularitySpec": {
+ "type": "uniform",
+ "segmentGranularity": "HOUR",
+ "queryGranularity": "MINUTE",
+ "rollup": false
+ }
+ },
+ "tuningConfig": {
+ "type": "kafka",
+ "reportParseExceptions": true
+ },
+ "ioConfig": {
+ "topic": "$topic",
+ "replicas": 1,
+ "startDelay": "PT1S",
+ "taskDuration": "PT1H",
+ "completionTimeout": "PT30M",
+ "consumerProperties": {
+ "bootstrap.servers": "$host"
+ },
+ "useEarliestOffset": true
+ }
+}