diff --git a/config.go b/config.go index d9cf469fe..74577b57a 100644 --- a/config.go +++ b/config.go @@ -189,7 +189,7 @@ type Config struct { // Return specifies what channels will be populated. If they are set to true, // you must read from them to prevent deadlock. Return struct { - // If enabled, any errors that occured while consuming are returned on + // If enabled, any errors that occurred while consuming are returned on // the Errors channel (default disabled). Errors bool } diff --git a/consumer.go b/consumer.go index b482371d1..869452754 100644 --- a/consumer.go +++ b/consumer.go @@ -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.