调试

@@ -26,6 +26,7 @@ func main() {
 		beego.Run()
 	}()
 	consumerRun := consumer.NewRuner()
+	logs.Debug("%+v", consumerRun)
 	if err := consumerRun.InitConsumer(); err != nil {
 		logs.Error("启动kafka消息消费者失败:%s", err)
 	}