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