Skip to content

Commit

Permalink
Fix HighWaterMarks() comment
Browse files Browse the repository at this point in the history
  • Loading branch information
Mathieu Payeur Levallois committed Oct 24, 2016
1 parent faf28b8 commit b0e729b
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,8 @@ 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
// Consistency between partitions is not garanteed since high water marks are updated separately.
HighWaterMarks() map[string]map[int32]int64

// Close shuts down the consumer. It must be called after all child
Expand Down

0 comments on commit b0e729b

Please sign in to comment.