|
|
@ -56,7 +56,11 @@ func start(config *config.Config, srv *server.AuthPostmanServer, cancel context. |
|
|
|
defer cancel() |
|
|
|
defer cancel() |
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
//
|
|
|
|
log.Printf("authPostmanServer starting (kafka listening to %s)\n", net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port))) |
|
|
|
kafkaStr := net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port)) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
|
|
|
|
log.Printf("authPostmanServer starting\n") |
|
|
|
|
|
|
|
log.Printf("authPostmanServer listening on %s\n", kafkaStr) |
|
|
|
|
|
|
|
|
|
|
|
// Запускаем прослушивание
|
|
|
|
// Запускаем прослушивание
|
|
|
|
if err := srv.ReadMessage(0); err != nil { |
|
|
|
if err := srv.ReadMessage(0); err != nil { |
|
|
|