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

Method client

writer.go:771–777  ·  view source on GitHub ↗
(timeout time.Duration)

Source from the content-addressed store, hash-verified

769}
770
771func (w *Writer) client(timeout time.Duration) *Client {
772 return &Client{
773 Addr: w.Addr,
774 Transport: w.Transport,
775 Timeout: timeout,
776 }
777}
778
779func (w *Writer) balancer() Balancer {
780 if w.Balancer != nil {

Callers 2

produceMethod · 0.95
partitionsMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected