diff --git a/producer/producer_config.go b/producer/producer_config.go
index 76d25a1..63964bf 100644
--- a/producer/producer_config.go
+++ b/producer/producer_config.go
@@ -4,6 +4,7 @@ import (
 	config "com.navi.medici.janus/config"
 
 	"time"
+	"strings"
 	"github.com/Shopify/sarama"
 	// "gopkg.in/confluentinc/confluent-kafka-go.v1/kafka"
 )
@@ -66,7 +67,7 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *sara
 
 func GetSyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.SyncProducer {
 	config := GetSyncProducerConfig(kafkaConfiguration)
-	brokerList := []string {kafkaConfiguration.Bootstrap_Servers}
+	brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, "")
 	producer, err := sarama.NewSyncProducer(brokerList, config)
 	if err != nil {
 		panic(err)
@@ -77,7 +78,7 @@ func GetSyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.SyncP
 
 func GetAsyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.AsyncProducer {
 	config := GetAsyncProducerConfig(kafkaConfiguration)
-	brokerList := []string {kafkaConfiguration.Bootstrap_Servers}
+	brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, "")
 	producer, err := sarama.NewAsyncProducer(brokerList, config)
 	if err != nil {
 		panic(err)