草庐IT

go - 使用 Shopify Sarama 的 Kafka 错误处理

所以我正在尝试将Kafka用于我的应用程序,它有一个生产者将操作记录到KafkaMQ中,而消费者则从MQ中读取它。由于我的应用程序是在Go中,我正在使用ShopifySarama来实现这一点.现在,我可以读取MQ并使用a打印消息内容fmt.Printf但是,我真的希望错误处理比控制台打印更好,而且我愿意付出更多努力。现在用于消费者连接的代码:mqCfg:=sarama.NewConfig()master,err:=sarama.NewConsumer([]string{brokerConnect},mqCfg)iferr!=nil{panic(err)//Don'twanttopani