Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
779
func
(w *Writer) balancer() Balancer {
780
if
w.Balancer != nil {
781
return
w.Balancer
782
}
783
return
&w.roundRobin
784
}
785
786
func
(w *Writer) maxAttempts() int {
787
if
w.MaxAttempts > 0 {
Callers
1
WriteMessages
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected