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

Method Errors

async_producer.go:65–65  ·  view source on GitHub ↗

Errors is the error output channel back to the user. You MUST read from this channel or the Producer will deadlock when the channel is full. Alternatively, you can set Producer.Return.Errors in your config to false, which prevents errors to be returned.

()

Source from the content-addressed store, hash-verified

63 // you can set Producer.Return.Errors in your config to false, which prevents
64 // errors to be returned.
65 Errors() <-chan *ProducerError
66
67 // IsTransactional return true when current producer is transactional.
68 IsTransactional() bool

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls