diff --git a/consumer.go b/consumer.go index af93e8a817..3ac3d94477 100644 --- a/consumer.go +++ b/consumer.go @@ -63,7 +63,7 @@ type Consumer interface { // or OffsetOldest ConsumePartition(topic string, partition int32, offset int64) (PartitionConsumer, error) - // HighWaterMarks returns the current high water marks for each topic and partitions + // HighWaterMarks returns the current high water marks for each topic and partition HighWaterMarks() map[string]map[int32]int64 // Close shuts down the consumer. It must be called after all child