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 16:07:43 +05:30
parent 73b93287eb
commit bb9ce0fbb9
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
producer/producer_config.go
View File

@@ -69,7 +69,7 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *sara
func GetSyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.SyncProducer {
config := GetSyncProducerConfig(kafkaConfiguration)
brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, "")
brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, ",")
producer, err := sarama.NewSyncProducer(brokerList, config)
if err != nil {
panic(err)
@@ -80,7 +80,7 @@ func GetSyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.SyncP
func GetAsyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.AsyncProducer {
config := GetAsyncProducerConfig(kafkaConfiguration)
brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, "")
brokerList := strings.Split(kafkaConfiguration.Bootstrap_Servers, ",")
producer, err := sarama.NewAsyncProducer(brokerList, config)
if err != nil {
panic(err)