[VOL-2778] Introducing Service definition in order to support the TT workflow
Change-Id: Ib171502e8940b5d0b219620a4503f7095d376d7a
diff --git a/internal/common/kafka_topic_config_test.go b/internal/common/kafka_topic_config_test.go
index bd3dd2e..4264df0 100644
--- a/internal/common/kafka_topic_config_test.go
+++ b/internal/common/kafka_topic_config_test.go
@@ -64,12 +64,15 @@
func TestInitializePublisher(t *testing.T) {
mockLib := mockSarama{}
+
+ Config = &GlobalConfig{}
+
err := InitializePublisher(mockLib.NewAsyncProducer, 0)
assert.Equal(t, err, nil)
assert.Equal(t, topic, "BBSim-OLT-0-Events")
- Options.BBSim.KafkaEventTopic = "Testing-Topic"
+ Config.BBSim.KafkaEventTopic = "Testing-Topic"
err = InitializePublisher(mockLib.NewAsyncProducer, 0)
assert.Equal(t, topic, "Testing-Topic")
assert.Equal(t, err, nil)