8 // SetKafkaParametersByObjectMap sets the value of the kafka parameters
9 // and sets the KafkaConfig object
10 func SetKafkaParametersByObjectMap(m map[string]interface{}) KafkaConfig {
12 kc.broker = m["broker"].(string)
13 kc.group = m["group"].(string)
14 kc.topic = m["topic"].(string)
19 // SetKafkaParametersByEnvVariables sets the kafka parameters
20 func SetKafkaParametersByEnvVariables() KafkaConfig {
21 slogger := GetLoggerInstance()
23 kafkaConfigObject := KafkaConfig{
24 broker: os.Getenv("BROKER"),
25 group: os.Getenv("GROUP"),
26 topic: os.Getenv("TOPIC"),
28 slogger.Infof("::broker:: %s", kafkaConfigObject.broker)
29 slogger.Infof("::group:: %s", kafkaConfigObject.group)
30 slogger.Infof("::topic:: %s", kafkaConfigObject.topic)
32 return kafkaConfigObject
35 // KafkaConfig contains all the config parameters needed for kafka. This can be extended over time
36 type KafkaConfig struct {
42 // GetBroker returns kafka broker configured
43 func (k KafkaConfig) GetBroker() string {
47 // GetGroup returns kafka group configured
48 func (k KafkaConfig) GetGroup() string {
52 // GetTopic returns kafka topic configured
53 func (k KafkaConfig) GetTopic() string {