wangzhongyang007 / goframe-shop-v2 Goto Github PK

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)
		}
	}
}