使用方法

conn, err := logger.NewConnection(
    config.Viper.GetStringSlice("KAFKA_SERVER"),
    config.Viper.GetString("KAFKA_TOPIC_CALLCHAIN"),
    0,
)
// 用户信息需在前一中间件中写入gin.Context
// 如 c.Set("user-info", "用户ID-用户名")
if err == nil {
    defer conn.Close()
    g.Use(logger.SetLogger(
        conn,
        logger.ConfigAppid(viper.GetString("KAFKA_LOG_APP_ID")),
        logger.ConfigEnvtype(viper.GetString("KAFKA_LOG_ENV_TYPE")),
        logger.ConfigLogname(viper.GetString("KAFKA_LOG_CALLCHAIN_NAME")),
        logger.ConfigLogthread(viper.GetString("KAFKA_LOG_THREAD")),
        logger.ConfigPort(strings.Trim(viper.GetString("RESTFUL_PORT"), ":")),
        logger.ConfigWithBody(viper.GetBool("KAFKA_LOG_BODY")),
    ))
}

conn, err := logger.NewConnection(
    config.Viper.GetStringSlice("KAFKA_SERVER"),
    config.Viper.GetString("KAFKA_TOPIC_INNER"),
    0,
)
if err == nil {
	logger.LogInner(c, conn,
		logger.WithAppid(viper.GetString("KAFKA_LOG_APP_ID")),
		logger.WithEnvtype(viper.GetString("KAFKA_LOG_ENV_TYPE")),
		logger.WithLogname(viper.GetString("KAFKA_LOG_INNER_NAME")),
		logger.WithLogthread(viper.GetString("KAFKA_LOG_THREAD")),
		logger.WithPort(strings.Trim(viper.GetString("RESTFUL_PORT"), ":")),
		// logger.WithUser("123-456"),
		// logger.WithThrowable("dddddd"),
		logger.WithLevel("INFO"),
		logger.WithLogKey("key"),
		logger.WithLogMsg("msg"),
    )
}