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

Function newLocalClient

compress/compress_test.go:492–494  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

490}
491
492func newLocalClient() (*kafka.Client, func()) {
493 return newClient(kafka.TCP("127.0.0.1:9092"))
494}
495
496func newClient(addr net.Addr) (*kafka.Client, func()) {
497 conns := &ktesting.ConnWaitGroup{

Callers 1

newLocalClientAndTopicFunction · 0.70

Calls 1

newClientFunction · 0.70

Tested by

no test coverage detected