MCPcopy
hub / github.com/IBM/sarama / Close

Method Close

consumer_group.go:71–71  ·  view source on GitHub ↗

Close stops the ConsumerGroup and detaches any running sessions. It is required to call this function before the object passes out of scope, as it will otherwise leak memory.

()

Source from the content-addressed store, hash-verified

69 // Close stops the ConsumerGroup and detaches any running sessions. It is required to call
70 // this function before the object passes out of scope, as it will otherwise leak memory.
71 Close() error
72
73 // Pause suspends fetching from the requested partitions. Future calls to the broker will not return any
74 // records from these partitions until they have been resumed using Resume()/ResumeAll().

Callers 13

ExampleConsumerGroupFunction · 0.95
TestConsumerGroupReasonFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95
CloseMethod · 0.65
newSessionMethod · 0.65
leaveMethod · 0.65
releaseMethod · 0.65

Implementers 1

consumerGroupconsumer_group.go

Calls

no outgoing calls