要并行启动 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()) }()如果没有，那么你拥有的就足够了。