We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
85a3803
Fix critical issue of kafkav2
w := &kafka.Writer{ Addr: kafka.TCP(k.addrs...), Balancer: &kafka.RoundRobin{}, BatchTimeout: 15 * time.Millisecond, }