[VOL-2778] Introducing Service definition in order to support the TT workflow
Change-Id: Ib171502e8940b5d0b219620a4503f7095d376d7a
diff --git a/internal/common/kafka_utils.go b/internal/common/kafka_utils.go
index c999539..c64646e 100644
--- a/internal/common/kafka_utils.go
+++ b/internal/common/kafka_utils.go
@@ -50,13 +50,13 @@
config.Metadata.Retry.Max = 10
config.Metadata.Retry.Backoff = 10 * time.Second
config.ClientID = "BBSim-OLT-" + strconv.Itoa(oltID)
- if len(Options.BBSim.KafkaEventTopic) > 0 {
- topic = Options.BBSim.KafkaEventTopic
+ if len(Config.BBSim.KafkaEventTopic) > 0 {
+ topic = Config.BBSim.KafkaEventTopic
} else {
topic = "BBSim-OLT-" + strconv.Itoa(oltID) + "-Events"
}
- producer, err = NewAsyncProducer([]string{Options.BBSim.KafkaAddress}, config)
+ producer, err = NewAsyncProducer([]string{Config.BBSim.KafkaAddress}, config)
return err
}