3 // Pipeline type represents a stucture of a general pipeline
5 KafkaConfiguration KafkaConfig `json:"kafkaConfig"`
6 HdfsConfiguration HdfsConfig `json:"hdfsConfig"`
9 // HdfsConfig type represents the config items of HDFS
10 type HdfsConfig struct {
11 HdfsURL string `json:"hdfs_url"`
14 // KafkaConfig type represents the config items of Kafka
15 type KafkaConfig struct {
16 Broker string `json:"broker"`
17 Group string `json:"group"`
18 Topic string `json:"topic"`