varnitgoyal95/janus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
“nishant-sharma”
2021-05-06 13:04:46 +05:30
parent 0cb73c3faf
commit 93e05701dc
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
producer/producer_config.go
View File

@@ -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)