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

Method Errors

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

Errors returns a read channel of errors that occurred during the consumer life-cycle. By default, errors are logged and not returned over this channel. If you want to implement any custom error handling, set your config's Consumer.Return.Errors setting to true, and read from this channel.

()

Source from the content-addressed store, hash-verified

65 // If you want to implement any custom error handling, set your config's
66 // Consumer.Return.Errors setting to true, and read from this channel.
67 Errors() <-chan error
68
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.

Callers 4

ExampleConsumerGroupFunction · 0.95
newConsumerGroupSessionFunction · 0.65
newConsumerGroupClaimFunction · 0.65
waitClosedMethod · 0.65

Implementers 1

consumerGroupconsumer_group.go

Calls

no outgoing calls

Tested by 1

ExampleConsumerGroupFunction · 0.76