|
|
@@ -255,7 +255,7 @@ type PartitionConsumer interface {
|
|
|
// the broker.
|
|
|
Messages() <-chan *ConsumerMessage
|
|
|
|
|
|
- // Errors returns a read channel of errors that occured during consuming, if
|
|
|
+ // Errors returns a read channel of errors that occurred during consuming, if
|
|
|
// enabled. 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.
|