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

Method Close

conn.go:539–541  ·  conn.go::Conn.Close

Close closes the kafka connection.

()

Source from the content-addressed store, hash-verified

537
538// Close closes the kafka connection.
539func (c *Conn) Close() error {
540 return c.conn.Close()
541}
542
543// LocalAddr returns the local network address.
544func (c *Conn) LocalAddr() net.Addr {

Callers 15

TestConnFunction · 0.95
prepareReaderFunction · 0.95
TestBatchDontExpectEOFFunction · 0.95
connectMethod · 0.95
ReadLagMethod · 0.95
SetOffsetAtMethod · 0.95
readOffsetFunction · 0.95
readPartitionFunction · 0.95
TestIssue477Function · 0.45
LookupPartitionMethod · 0.45
LookupPartitionsMethod · 0.45
connectTLSMethod · 0.45

Calls

no outgoing calls

Tested by 15

TestConnFunction · 0.76
prepareReaderFunction · 0.76
TestBatchDontExpectEOFFunction · 0.76
readOffsetFunction · 0.76
readPartitionFunction · 0.76
TestIssue477Function · 0.36
createTopicFunction · 0.36
deleteTopicFunction · 0.36
BenchmarkReaderFunction · 0.36
TestCloseLeavesGroupFunction · 0.36
testConsumerGroupImmediateCloseFunction · 0.36
testConsumerGroupSimpleFunction · 0.36