要并行启动 Kafka 消费者和 HTTP 服务器？

Question

有没有办法有效地并行启动 go-server 和 kafka Consumer。我在做什么在下面？go consumers.KafkaConsumer() router := router.NewRouter() log.Fatal(http.ListenAndServe(":8001", router))这是正确的方法还是有其他方法可以做到这一点？

Answer 1

你正在做的事情是正确的。如果有可能consumers.KafkaConsumer因错误而终止，您可能需要处理：

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

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