Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ writeTimeout
Method
writeTimeout
writer.go:839–844 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
837
}
838
839
func
(w *Writer) writeTimeout() time.Duration {
840
if
w.WriteTimeout > 0 {
841
return
w.WriteTimeout
842
}
843
return
10 * time.Second
844
}
845
846
func
(w *Writer) withLogger(do
func
(Logger)) {
847
if
w.Logger != nil {
Callers
2
produce
Method · 0.95
Stats
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected