internal/mq/kafka/kafka.go有报错了

[liliewin]

文件路径：internal/mq/kafka/kafka.go
这里有报错

func init() {
	mq, err := g.Cfg().Get(gctx.New(), "mq")
	if err != nil {
		panic(err)
	}
	ip := mq.Map()["kafka"].(string) // 这里有报错
	pool := []string{ip}
	builder := NewKafkaBuilder(pool)
	kafkaPool := NewKafkaPool().SetBuilder(builder)
	err = kafkaPool.Init()
	if err != nil {
		fmt.Println("初始化kafka失败：", err.Error())
		os.Exit(1)
	}
}

改成

func init() {
	mq, err := g.Cfg().Get(gctx.New(), "mq")
	if err != nil {
		panic(err)
	}
	if ip, ok := mq.Map()["kafka"].(string); ok {  //  改
		pool := []string{ip}
		builder := NewKafkaBuilder(pool)
		kafkaPool := NewKafkaPool().SetBuilder(builder)
		err = kafkaPool.Init()
		if err != nil {
			fmt.Println("初始化kafka失败：", err.Error())
			os.Exit(1)
		}
	}
}

[wangzhongyang007]

这是来自QQ邮箱的假期自动回复邮件。   您好，我最近正在休假中，无法亲自回复您的邮件。我将在假期结束后，尽快给您回复。

[canyonwan]

直接提pr啊

[liliewin]

这是一封自动回复邮件。已经收到您的来信，我会尽快回复。

[wangzhongyang007]

这是来自QQ邮箱的假期自动回复邮件。   您好，我最近正在休假中，无法亲自回复您的邮件。我将在假期结束后，尽快给您回复。