Переглянути джерело

Merge pull request #526 from yangfan876/patch-1

Update consumer.go
Evan Huus 9 роки тому
батько
коміт
28da3515db
1 змінених файлів з 1 додано та 1 видалено
  1. 1 1
      consumer.go

+ 1 - 1
consumer.go

@@ -250,7 +250,7 @@ type PartitionConsumer interface {
 	Messages() <-chan *ConsumerMessage
 
 	// Errors returns a read channel of errors that occured during consuming, if enabled. By default,
-	// errors are logged and not returned over this channel. If you want to implement any custom errpr
+	// 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.
 	Errors() <-chan *ConsumerError