Skip to content

set and test: limit timeout to publish 15ms

Latest
Compare
Choose a tag to compare
@teng231 teng231 released this 10 Aug 17:48
· 3 commits to master since this release

Fix critical issue of kafkav2

w := &kafka.Writer{
		Addr:         kafka.TCP(k.addrs...),
		Balancer:     &kafka.RoundRobin{},
		BatchTimeout: 15 * time.Millisecond,
	}