# gin-kafka-logger

**Repository Path**: wxlao/logger

## Basic Information

- **Project Name**: gin-kafka-logger
- **Description**: Gin-Kafka-Logger
- **Primary Language**: Go
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-01-02
- **Last Updated**: 2021-03-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 使用方法
## 中间件
```go
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")),
    ))
}

```

## 应用日志
```go
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"),
    )
}
```