From bb9ce0fbb989b99cd61633c9fd1ae56bb90e7f4d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E2=80=9Cnishant-sharma=E2=80=9D?= Date: Thu, 6 May 2021 16:07:43 +0530 Subject: [PATCH] bug fix --- producer/producer_config.go | 4 ++-- server/handlers.go | 15 ++++++++------- 2 files changed, 10 insertions(+), 9 deletions(-) diff --git a/producer/producer_config.go b/producer/producer_config.go index e4daae6..8152fe2 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -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) diff --git a/server/handlers.go b/server/handlers.go index 1052018..686b3e7 100644 --- a/server/handlers.go +++ b/server/handlers.go @@ -4,6 +4,7 @@ import ( lib "com.navi.medici.janus/lib" "io" + // "fmt" "io/ioutil" "log" "net/http" @@ -18,6 +19,13 @@ var ( func eventsHandler(w http.ResponseWriter, r *http.Request) { var reader io.Reader + // for name, values := range r.Header { + // // Loop over all values for the name. + // for _, value := range values { + // fmt.Println("HEADER: ", name, value) + // } + // } + // check if body is gzip compressed if r.Header.Get("Content-Encoding") == "gzip" { var err error @@ -49,13 +57,6 @@ func eventsHandler(w http.ResponseWriter, r *http.Request) { func eventsHandlerJson(w http.ResponseWriter, r *http.Request) { var reader io.Reader - for name, values := range r.Header { - // Loop over all values for the name. - for _, value := range values { - log.Println(name, value) - } - } - // check if body is gzip compressed if r.Header.Get("Content-Encoding") == "gzip" { var err error