main.go

package main

import (
	"fmt"
	"strings"

	"github.com/astaxie/beego"
	"github.com/astaxie/beego/context"
	"github.com/astaxie/beego/logs"
	"github.com/astaxie/beego/orm"
	_ "github.com/mattn/go-sqlite3"
	"github.com/optiopay/kafka/v2"
	"github.com/spf13/viper"
	"github.com/xiaof-github/kafdrop-go/kafgo"
	_ "github.com/xiaof-github/kafdrop-go/routers"
)

func main() {	
    viper.SetConfigName("app")
    viper.AddConfigPath("conf")
    err := viper.ReadInConfig()
    if err != nil {
        panic(fmt.Errorf("Fatal error config file: %s \n", err))
    }
    addr := viper.GetString("kafka.addr")

    addrs := strings.Split(addr, ",")	
    fmt.Println(addrs)
    fmt.Println(kafgo.OFFSET_INIT)
	
	// connect to kafka cluster
	broker, err := kafka.Dial(addrs, kafka.NewBrokerConf("test"))
	if err != nil {
		panic(err)
	}
    defer broker.Close()
    
	kafgo.Broker = broker

    //注册sqlite3
    orm.RegisterDataBase("default", "sqlite3", "go-admin.db")
    //同步 ORM 对象和数据库
    //这时, 在你重启应用的时候, beego 便会自动帮你创建数据库表。
    orm.Debug = true

    orm.RunSyncdb("default", false, true)

    //增加拦截器。
    var filterAdmin = func(ctx *context.Context) {
        url := ctx.Input.URL()
        logs.Info("##### filter url : %s", url)
        //TODO 如果判断用户未登录。

    }
    beego.InsertFilter("/admin/*", beego.BeforeExec, filterAdmin)

    beego.Run()
}