| @@ -16,7 +16,7 @@ import ( | |||||
| ) | ) | ||||
| func main() { | func main() { | ||||
| HttpServer("127.0.0.1:1902") | |||||
| HttpServer("0.0.0.0:1902") | |||||
| } | } | ||||
| func HttpServer(addr string) { | func HttpServer(addr string) { | ||||
| @@ -25,13 +25,13 @@ func HttpServer(addr string) { | |||||
| methodsOk := handlers.AllowedMethods([]string{"GET", "HEAD", "POST", "PUT", "DELETE", "OPTIONS"}) | methodsOk := handlers.AllowedMethods([]string{"GET", "HEAD", "POST", "PUT", "DELETE", "OPTIONS"}) | ||||
| // Kafka writer that relays messages | // Kafka writer that relays messages | ||||
| writer := kafkaWriter("127.0.0.1:9092", "apibeacons") | |||||
| writer := kafkaWriter("kafka:9092", "apibeacons") | |||||
| defer writer.Close() | defer writer.Close() | ||||
| r := mux.NewRouter() | r := mux.NewRouter() | ||||
| client := redis.NewClient(&redis.Options{ | client := redis.NewClient(&redis.Options{ | ||||
| Addr: "127.0.0.1:6379", | |||||
| Addr: "kafka:6379", | |||||
| Password: "", | Password: "", | ||||
| }) | }) | ||||