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>

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
+	}
+}