有沒有辦法有效地并行啟動 go-server 和 kafka Consumer。我在做什么在下面？go consumers.KafkaConsumer()
router := router.NewRouter()
log.Fatal(http.ListenAndServe(":8001", router))這是正確的方法還是有其他方法可以做到這一點？
1 回答
慕無忌1623718
TA貢獻1744條經(jīng)驗 獲得超4個贊
你正在做的事情是正確的。如果有可能consumers.KafkaConsumer因錯誤而終止，您可能需要處理：
go func() {
log.Fatal(consumers.KafkaConsumer())
}()如果沒有，那么你擁有的就足夠了。
- 1 回答
- 0 關注
- 145 瀏覽
添加回答
舉報
0/150
提交
取消