# producer

**Repository Path**: gomods/producer

## Basic Information

- **Project Name**: producer
- **Description**: No description available
- **Primary Language**: Go
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-09-26
- **Last Updated**: 2026-04-09

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# producer 消息生产代理

消息生产者代理，支持 `kafka`, `redis`, `delay` 等类型。

## 安装

```shell script
go get gitee.com/gomods/producer
```

## 配置

```ini
[MQProxy]
; 灰度模式
grayMode = false

[KafkaProxy]
enable = true
; 调整 confluent-kafka-go 作为基础包，sarama 保留，手动配置 type=sarama 开启, 默认: confluent
;type=sarama
KafkaWaitAll = true
KafkaCompression = true
KafkaPartitioner = round
KafkaProducerTimeout = 10
brokers = localhost:9092
sasl = false
user =
password =
valid = tal_exercise_submit tal_exam_submit
;消息失败处理模式，支持retry(重试)/save(保存到redis)/discard(直接丢弃)，默认为retry
failMode = discard
```

### 开始

```go
// 导入库
import gitee.com/gomods/producer

// kafka 投递示例
producer.Kafka("kafka_topic", []byte("msg context..."))

// 投递 redis 队列
; rdsClient = redis 实例
producer.Redis(rdsClient, "udc_rds_list", []byte("msg context..."))

// 延迟消息投递示例
producer.Delay(rdsClient, "udc_rds_delay", []byte("msg context..."), 1684627485)
```