X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=vnfs%2FDAaaS%2Fmicroservices%2FGoApps%2Fsrc%2Fgo-hdfs-writer%2Fpkg%2Futils%2Fkafka-config.go;fp=vnfs%2FDAaaS%2Fmicroservices%2FGoApps%2Fsrc%2Fgo-hdfs-writer%2Fpkg%2Futils%2Fkafka-config.go;h=0000000000000000000000000000000000000000;hb=68d118176bb53c36b31a7060cfa16ad5acac1765;hp=080bfd4bbb8a35ce54423d3c83afdda6c94a6b89;hpb=68042495ef1e1e6dff7fed7fc2691b01cf672fe1;p=demo.git

diff --git a/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/kafka-config.go b/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/kafka-config.go
deleted file mode 100644
index 080bfd4b..00000000
--- a/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/kafka-config.go
+++ /dev/null
@@ -1,55 +0,0 @@
-package utils
-
-
-import (
-	"os"
-)
-
-// SetKafkaParametersByObjectMap sets the  value of the kafka parameters
-// and sets the KafkaConfig object 
-func SetKafkaParametersByObjectMap(m map[string]interface{}) KafkaConfig {
-	kc := KafkaConfig{}
-	kc.broker = m["broker"].(string)
-	kc.group = m["group"].(string)
-	kc.topic = m["topic"].(string)
-
-	return kc
-}
-
-// SetKafkaParametersByEnvVariables sets the kafka parameters
-func SetKafkaParametersByEnvVariables() KafkaConfig {
-	slogger := GetLoggerInstance()
-	
-	kafkaConfigObject := KafkaConfig{
-		broker: os.Getenv("BROKER"),
-		group: os.Getenv("GROUP"),
-		topic: os.Getenv("TOPIC"),
-	}
-	slogger.Infof("::broker:: %s", kafkaConfigObject.broker)
-	slogger.Infof("::group:: %s", kafkaConfigObject.group)
-	slogger.Infof("::topic:: %s", kafkaConfigObject.topic)
-
-	return kafkaConfigObject
-}
-
-// KafkaConfig contains all the config parameters needed for kafka. This can be extended over time
-type KafkaConfig struct {
-	broker string
-	group string
-	topic string
-}
-
-// GetBroker returns kafka broker configured
-func (k KafkaConfig) GetBroker() string {
-	return k.broker
-}
-
-// GetGroup returns kafka group configured
-func (k KafkaConfig) GetGroup() string {
-	return k.group
-}
-
-// GetTopic returns kafka topic configured
-func (k KafkaConfig) GetTopic() string {
-	return k.topic
-}
\ No newline at end of file