go - 要同时启动Kafka使用者和HTTP服务器？

Question

有没有一种方法可以有效地启动go-server和kafka用户并行。
我在做什么下面？

go consumers.KafkaConsumer()
router := router.NewRouter()
log.Fatal(http.ListenAndServe(":8001", router))

这是正确的方法还是有其他方法可以做到这一点？

Answer 1

你在做什么是对的。如果consumers.KafkaConsumer有可能因错误而终止，则您可能要处理以下问题:

go func() {
  log.Fatal(consumers.KafkaConsumer())
}()

如果没有，那么您所拥有的就足够了。