MCPcopy
hub / github.com/segmentio/kafka-go / balancer

Method balancer

writer.go:779–784  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

777}
778
779func (w *Writer) balancer() Balancer {
780 if w.Balancer != nil {
781 return w.Balancer
782 }
783 return &w.roundRobin
784}
785
786func (w *Writer) maxAttempts() int {
787 if w.MaxAttempts > 0 {

Callers 1

WriteMessagesMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected