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

Method Close

consumer.go:76–76  ·  view source on GitHub ↗

Close shuts down the consumer. It must be called after all child PartitionConsumers have already been closed.

()

Source from the content-addressed store, hash-verified

74 // Close shuts down the consumer. It must be called after all child
75 // PartitionConsumers have already been closed.
76 Close() error
77
78 // Pause suspends fetching from the requested partitions. Future calls to the broker will not return any
79 // records from these partitions until they have been resumed using Resume()/ResumeAll().

Callers 14

TestFuncTxnProduceFunction · 0.95
ExampleConsumerFunction · 0.95
consumeWithSaramaFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95

Implementers 2

consumerconsumer.go
Consumermocks/consumer.go

Calls

no outgoing calls

Tested by 9

TestFuncTxnProduceFunction · 0.76
ExampleConsumerFunction · 0.76
consumeWithSaramaFunction · 0.76