Skip to content

Commit

Permalink
Update kafka
Browse files Browse the repository at this point in the history
  • Loading branch information
kesonan committed Jul 22, 2024
1 parent 2e7074f commit a22ac39
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion docs/tutorials/queue/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -266,7 +266,7 @@ func main() {
}
```

当然,consumer 中在 mqs.go 中 kq.MustNewQueue 初始化时候点个参数也是可选参数
当然,consumer 中在 mqs.go 中 kq.MustNewQueue 初始化时候这个参数也是可选参数

- commitInterval : 提交给 kafka broker 间隔时间,默认是 1s
- queueCapacity:kafka 内部队列长度
Expand Down

0 comments on commit a22ac39

Please sign in to comment.