Update notification_handler.go

Author: akshatvg

wrappers/notification_handler/notification_handler.go

@@ -39,7 +39,7 @@ func NewNotificationHandlerWrapper(config boilerplate.WrapperConfig) INotificati
 		env := boilerplate.GetCurrentEnvironment().ToString()
 		w.publisher = eventsourcing.NewKafkaEventPublisher(
 			boilerplate.KafkaWriterConfiguration{
-				Hosts: "kafka-0.kafka-headless.kafka.svc.cluster.local:9092,kafka-1.kafka-headless.kafka.svc.cluster.local:9092",
+				Hosts: "kafka.kafka.svc.cluster.local:9092",
 				Tls:   false,
 			}, boilerplate.KafkaTopicConfig{
 				Name:              fmt.Sprintf("%v.notifications.handler_sending_queue", env),
@@ -49,7 +49,7 @@ func NewNotificationHandlerWrapper(config boilerplate.WrapperConfig) INotificati
 
 		w.customPublisher = eventsourcing.NewKafkaEventPublisher(
 			boilerplate.KafkaWriterConfiguration{
-				Hosts: "kafka-0.kafka-headless.kafka.svc.cluster.local:9092,kafka-1.kafka-headless.kafka.svc.cluster.local:9092",
+				Hosts: "kafka.kafka.svc.cluster.local:9092",
 				Tls:   false,
 			}, boilerplate.KafkaTopicConfig{
 				Name:              fmt.Sprintf("%v.notifications.handler_sending_queue_custom", env),